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