陈什什什

可以了~

1、改成你的内网ip就可以了，默认会绑定到外网的。

listeners=PLAINTEXT://{你的内网ip}:9093

advertised.listeners和host.name都删了吧，已经过时了。

2、你的错误是

[2021-03-04 17:27:38,160] ERROR Error while creating ephemeral at /brokers/ids/0, node already exists and owner '72068832371015680' does not match current session '72068893612310528' (kafka.zk.KafkaZkClient$CheckedEphemeral)

有脏数据，清理一下zk的数据和kafka的数据。

如果没有任何数据 也没有报错 那这个topic里没有任何消息。

[root@localhost kafka_2.12-2.0.1]# bin/kafka-console-consumer.sh --bootstrap-server *****:9092 --topic testof1 --from-beginning
[root@localhost kafka_2.12-2.0.1]#

这是命令执行之后的，之前正常的时候应该像这篇文章中说到的那样，我这里就直接没反应

应该最后会报超时，java既然成功了，应该配置的不是localhost:9092这个，换成跟java一样具体的ip试试。