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

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

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

尝试这个命令 -

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

Answer 2

问题似乎是由于旧 Kafka/Zookeeper 设置与新设置之间的变化所致。 在旧版本中，我们应该使用 --zookeeper 选项和端口 2181（默认情况下）；然而，对于新的 Kafka/Zookeeper 版本，用户预计默认使用端口 9092 与客户 API。 当使用端口 2181 的新 Kafka 发出 API 时，我们收到错误 java.io.IOException: Unreasonable length。

Answer 3

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

Answer 4

zookeeper 中不合理的长度 = 308375649 谢谢 dhanesh24g，帮助我解决了问题。

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

我从旧的卡夫卡主题复制，所以它有动物园管理员和动物园管理员端口。 我将 --zookeeper 修改为 --bootstrap-server 但没有注意到端口。