Zookeeper中的错误：在Kafka中创建主题时不合理的长度= 308375649

Question

我正在本地 Windows 10 计算机上设置 Kafka。因此，下载了所有必需的二进制文件，并根据文档更新了两个设置服务器和 Zookeeper 属性。

但是当运行 Kafka create topic 命令时

kafka-topics.bat --create --bootstrap-server 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic testtopic

我在 Zookeeper 窗口中收到以下错误

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)

有人可以帮我吗？

Answer 1

我遇到了类似的问题，因为我试图在提供--bootstrap-server选项的同时连接到 Zookeeper 实例（端口 2181）。后来，我提供了 Kafka 代理详细信息（localhost：9092）并且工作正常。

在旧的 Kafka 版本中，我们曾经提供--zookeeper选项以及它的实例。

尝试这个命令 -

bin/kafka-topics.sh --create --topic testtopic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1