[2022-02-25 15:14:49,439] WARN [Producer clientId=console-producer] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2022-02-25 15:14:49,442] WARN [Producer clientId=console-producer] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
org.apache.kafka.common.KafkaException: Producer closed while send in progress
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:929)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:905)
命令用错了,新版本kafka启动,不再使用--broker-listr:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic1
应该是:
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic topic1
使用时需要注意新版本的变化。