我有一个正在工作的kafka示例,但现在它产生了数千个错误,如下所示:
[2016-06-24 01:33:28092]错误[broker 0上的副本管理器]:处理来自相关id为85452的使用者的分区[test topic,0]偏移量45的获取请求时出错。可能原因:请求偏移量45,但我们只有0到0范围内的日志段(kafka.server.replicamanager(复制管理器)
我使用的是默认配置。我在node.js代码中使用了几个主题。
upd:重新安装Kafka对我有帮助,但我想知道问题的根源。
1条答案
按热度按时间qv7cva1a1#
请阅读这里的问题的来源https://github.com/endgameinc/elasticsearch-river-kafka/issues/8
您可能已经删除了Kafka中的一些文件或文件夹。