每次启动后都自动的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
网友评论