每次启动后都自动的shut down了
日志中会有如下错误:
还不知道具体的原因,症结在于leader选取出错,解决方案:
设置server.properties中的配置:
unclean.leader.election.enable=true
该配置默认的是false
unclean.leader.election.enable = false
命令行kafka-consumer-group.sh执行中报的异常信息:
WARN Connection to node -1 could not be established. Broker may not be available
链接中的某个节点的kafka服务可能down了,查看一下
关于这个问题的讨论:
https://issues.apache.org/jira/browse/KAFKA-3410
关于Kafka不丢失消息的一些配置介绍:
来源:No data loss pipeline with apache kafka.pdf
https://www.slideshare.net/JiangjieQin/no-data-loss-pipeline-with-apache-kafka-49753844
网友评论