首页   快速返回

kafka1.1.0无法消费问题     所属分类 kafka
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

上一篇     下一篇
elasticsearch term match match_phrase 区别

postman中form-data x-www-form-urlencoded raw binary的区别

elasticsearch term 和 match

JMX配置及java客户端远程连接JMX端口

AQS要点整理

自定义类加载器例子