kafka1.1.0 单节点

org.apache.kafka.kafka_2.12:1.1.0
org.apache.kafka.kafka-clients:1.1.0


可以正常发送数据
但是无法消费 一直卡在 AbstractCoordinator ensureCoordinatorReady 方法里
log.debug("Coordinator discovery failed, refreshing metadata");
client.awaitMetadataUpdate(remainingMs);
           
检查zk数据 
保留 offset 的 topic 没有创建
/brokers/topics/__consumer_offsets

原来是值部署了一个节点 ，但是配置文件中默认副本数为 2 ，无法创建 __consumer_offsets
消费端一直等待

修改kafka配置 重启后 可以正常 发送 消费数据

config/server.properties


/Users/dugang/soft/elk/kafka1.1.0

启动zk 和 kafka 
./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties 
./bin/kafka-server-start.sh -daemon   ./config/server.properties 


停止kafka和zk

./bin/kafka-server-stop.sh
./bin/zookeeper-server-stop.sh