当试图设置Kafka在2奴隶和1主框,得到了一个奇怪的条件,我不能消费或产生一个主题。
使用mirror maker在从属<-->master之间同步数据。无休止地获取以下日志:
[2016-08-26 14:28:33897]警告引导代理localhost:9092 disconnected (org.apache.kafka.clients.networkclient)[2016-08-26 14:28:43515]警告引导代理localhost:9092 disconnected (org.apache.kafka.clients.networkclient)[2016-08-26 14:28:45,118]警告引导代理localhost:9092 disconnected (org.apache.kafka.clients.networkclient)[2016-08-26 14:28:46721]警告引导代理localhost:9092 disconnected (org.apache.kafka.clients.networkclient)[2016-08-26 14:28:48,324]警告引导代理localhost:9092 disconnected (org.apache.kafka.clients.networkclient)[2016-08-26 14:28:49927]警告引导代理localhost:9092 disconnected (org.apache.kafka.clients.networkclient)[2016-08-26 14:28:53029]警告引导代理localhost:9092 disconnected (org.apache.kafka.clients.networkclient)**
我唯一可以恢复的方法是重新启动kafka,它产生了这样的日志:
[2016-08-26 14:30:54856]警告发现损坏的索引文件,/tmp/kafka logs/\uu consumer\u offsets-43/00000000000000000000.index,正在删除和重建索引(kafka.log.log)[2016-08-26 14:30:54856]信息恢复日志中未冲洗的段0\uu消费者\u-43(kafka.log.log)[2016-08-26 14:30:54857]信息已完成加载日志\u consumer\u offsets-43,日志结束偏移量为0(kafka.log.log)[2016-08-26 14:30:54860]警告发现损坏的索引文件,/tmp/kafka logs/\u consumer\u offsets-26/00000000000000000000.index,正在删除和重建索引(kafka.log.log)[2016-08-26 14:30:54860]正在恢复日志\uu-26中未刷新的段0的信息(kafka.log.log)[2016-08-26 14:30:54861]信息已完成加载日志\u consumer\u offsets-26,日志结束偏移量为0(kafka.log.log)[2016-08-26 14:30:54864]警告发现损坏的索引文件,/tmp/kafka logs/\u consumer\u offsets-35/00000000000000000000.index,正在删除和重建索引(Kafka.log.log)**
向主题dr\u ubr\u analytics\u limits发送消息时出错,键为null,值为1字节,错误为:(org.apache.kafka.clients.producer.internals.errorloggingcallback)org.apache.kafka.common.errors.timeoutexception:60000毫秒后更新元数据失败**
这是我的测试阶段,所以我能够重新启动和恢复从主盒,但我想知道是什么原因导致这个问题,以及如何可以避免。有没有办法调试这个问题?
试图通过Kafka实现追随
暂无答案!
目前还没有任何答案,快来回答吧!