控制台消费者、生产者都正常运行,代码生产者消费者也都能正常运行,唯独控制台查看topic列表、创建topic这些命令报如下错误
kafka-topics.bat --list --bootstrap-server localhost:2181
Error while executing topic command : Timed out waiting for a node assignment. Call: listTopics
[2022-07-04 15:26:04,887] ERROR org.apache.kafka.common.errors.TimeoutException:
Timed out waiting for a node assignment. Call: listTopics
(kafka.admin.TopicCommand$)
[2022-07-04 15:54:29,060] WARN Close of session 0x0 (org.apache.zookeeper.server.NIOServerCnxn)
java.io.IOException: Unreasonable length = 308375649
at org.apache.jute.BinaryInputArchive.checkLength(BinaryInputArchive.java:166)
at org.apache.jute.BinaryInputArchive.readBuffer(BinaryInputArchive.java:127)
at org.apache.zookeeper.proto.ConnectRequest.deserialize(ConnectRequest.java:91)
at org.apache.zookeeper.server.ZooKeeperServer.processConnectRequest(ZooKeeperServer.java:1350)
at org.apache.zookeeper.server.NIOServerCnxn.readConnectRequest(NIOServerCnxn.java:419)
at org.apache.zookeeper.server.NIOServerCnxn.readPayload(NIOServerCnxn.java:180)
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:339)
at org.apache.zookeeper.server.NIOServerCnxnFactory$IOWorkRequest.doWork(NIOServerCnxnFactory.java:522)
at org.apache.zookeeper.server.WorkerService$ScheduledWorkRequest.run(WorkerService.java:154)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
网上查了众多方法,大部分提示修改配置文件中的“listeners”和“advertised.listeners”参数,但我尝试了默认配置,仅设置其中一个,两个均设置都无法解决。
另:我的配置文件中仅修改了server.properties和zookeeper.properties的log目录,其他参数未做修改
目前来看是不影响kafka使用的,但还是想弄清楚原因。