卡夫卡- "Received -1 from channel reading from source socket has likely been closed"
Kafka- "Received -1 from channel reading from source socket has likely been closed"
我首先使用命令
创建一个主题测试
/opt/cloudera/parcels/KAFKA/bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
然后当我尝试使用命令
向 Kafka 中的主题插入新消息时
/opt/cloudera/parcels/KAFKA/bin/kafka-console-producer --broker-list localhost:2181 --topic test
然后我输入一条消息 "name":"Ashish"
我收到错误
"received -1 from channel reading from source socket has likely been
closed" !
我做错了什么？
任何指向解决方案或帮助的指示都将不胜感激。
--broker-list 参数期望 Kafka 代理 Id 而不是 zookeeper 代理。在您的情况下，您提到了动物园管理员 host:port，它位于端口 2181 的 运行。默认情况下，kafka 代理监听端口 9092。
把--broker-host localhost:2181改成--broker-host localhost:9092看看有没有帮助（假设kafka broker在运行同一台机器，否则把lcoalhost换成机器ip）
我首先使用命令
创建一个主题测试/opt/cloudera/parcels/KAFKA/bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
然后当我尝试使用命令
向 Kafka 中的主题插入新消息时/opt/cloudera/parcels/KAFKA/bin/kafka-console-producer --broker-list localhost:2181 --topic test
然后我输入一条消息 "name":"Ashish"
我收到错误
"received -1 from channel reading from source socket has likely been closed" !
我做错了什么？
任何指向解决方案或帮助的指示都将不胜感激。
--broker-list 参数期望 Kafka 代理 Id 而不是 zookeeper 代理。在您的情况下，您提到了动物园管理员 host:port，它位于端口 2181 的 运行。默认情况下，kafka 代理监听端口 9092。
把--broker-host localhost:2181改成--broker-host localhost:9092看看有没有帮助（假设kafka broker在运行同一台机器，否则把lcoalhost换成机器ip）