java获取kafka偏移量_java – Kafka日志中缺少偏移量 – 简单消费者无法继续
我有一个3节点kafka群集设置.我正在使用风暴来阅读来自kafka的消息.我系统中的每个主题都有7个分区.现在我面临一个奇怪的问题.直到3天前,一切都运转良好.但是,现在看来我的风暴拓扑无法从2个分区 – #1和#4中专门读取.我试图深入研究这个问题并发现在我的kafka日志中,对于这两个分区,一个偏移量丢失,即在5964511之后,下一个偏移量是5964513而不是5964512.由于缺少偏移...
