详细报错信息如下:

[root@kafka1 bin]# ./kafka-console-producer.sh -broker-list kafka1:9092,kafka2:9092,kafka3:9092 -topic test
[2019-04-24 08:52:56,252] WARN Bootstrap broker kafka2:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:52:57,757] WARN Bootstrap broker kafka1:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:52:59,259] WARN Bootstrap broker kafka3:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:00,861] WARN Bootstrap broker kafka2:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:02,363] WARN Bootstrap broker kafka1:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:03,866] WARN Bootstrap broker kafka2:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:05,368] WARN Bootstrap broker kafka3:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:06,871] WARN Bootstrap broker kafka1:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:08,374] WARN Bootstrap broker kafka2:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:09,876] WARN Bootstrap broker kafka3:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:11,478] WARN Bootstrap broker kafka2:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2019-04-24 08:53:12,981] WARN Bootstrap broker kafka1:9092 disconnected (org.apache.kafka.clients.NetworkClient)

原因为jdk版本错误:

kafka_2.11-0.10.0.1.tgz需要jdk1.8版本,原来用的jdk1.7版本,替换jdk为1.8之后重启kafka正常。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐