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



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

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

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

我在动物园管理员窗口中得到以下错误

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)

有人能帮我吗?

我遇到了类似的问题,因为我试图连接到zookeeper实例(端口2181(,同时提供--bootstrap服务器选项。后来,我提供了Kafka代理的详细信息(localhost:9092(&它运行良好。

在旧的Kafka版本中,我们曾经提供--zookeeper选项&因此它的实例。

试试这个命令-

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

这个问题似乎是因为旧的Kafka/Zookeeper设置与新的设置之间的变化。在旧版本中,我们应该使用--zookeeper选项和端口2181(默认情况下(;然而,对于新的Kafka/Zookeeper版本,用户默认情况下会使用客户API的9092端口。当使用端口为2181的新Kafka发布API时,我们会得到错误java.io.IOException:长度不合理

使用以下命令kafka-topics.bat--describe--主题testtopic--引导服务器localhost:9092

最新更新