Nat*_*lia
9
apache-kafka
我正在运行与kafka合作已有一年的服务,并且没有发生领导者的自发变化.但是在过去的两周里,这种情况经常发生.卡夫卡登录:
- [2015-09-27 15:35:14,826] INFO [代理2上的ReplicaFetcherManager]删除了分区的抓取器[myTopic](kafka.server.ReplicaFetcherManager)
- [2015-09-27 15:35:14,830] INFO截断日志myTopic-0以抵消11520979.(kafka.log.Log)
- [2015-09-27 15:35:14,845] WARN [Broker 2上的副本管理器]:在分区[myTopic,0]上从客户端ReplicaFetcherThread-0-2获取具有相关ID 713276的请求失败,因为Leader不是本地分区[经纪人2上的myTopic,0](kafka.server.ReplicaManager)
- [2015-09-27 15:35:14,857] WARN [Broker 2上的副本管理器]:在分区[myTopic,0]上从客户端mirrormaker-1获取具有相关ID 256685的请求失败,因为Leader不是本地分区[myTopic,代理商2上的0](kafka.server.ReplicaManager)
- [2015-09-27 15:35:20,171] INFO [代理2上的ReplicaFetcherManager]删除分区的抓取器[myTopic,0](kafka.server.ReplicaFetcherManager)
什么可以导致转换领导者？如果某些kafka文档中有信息 - 请 - 只需指向该链接即可.我没找到.
系统配置
kafka版本:kafka_2.10-0.8.2.1
os:Red Hat Enterprise Linux Server 6.5版(圣地亚哥)
server.properties(与默认值不同):
- broker.id = 001
- socket.send.buffer.bytes = 1048576
- socket.receive.buffer.bytes = 1048576
- socket.request.max.bytes = 104857600
- log.flush.interval.messages = 10000
- log.flush.interval.ms = 1000
- log.retention.bytes = -1
- controlled.shutdown.enable =真
- auto.create.topics.enable = FALSE