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

Question

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

但是在运行 Kafka 创建主题命令时

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

Answer 2

使用以下命令 kafka-topics.bat --describe --topic testtopic --bootstrap-server localhost:9092