Kafka(0.9.0.0) 给出 ArrayIndexOutOfBoundsException答案

【问题标题】：Kafka(0.9.0.0) gives ArrayIndexOutOfBoundsExceptionKafka(0.9.0.0) 给出 ArrayIndexOutOfBoundsException
【发布时间】：2018-10-26 04:33:17
【问题描述】：

接下来的步骤：

cd /opt/kafka_2.11-0.9.0.0

bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1  --partitions 1 --topic topic-test

bin/kafka-topics.sh --list --zookeeper localhost:2181

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic-test

发生时间：当您在生产者 bash 中写入任何内容时，就会出现此错误

已经尝试过：从 zookeper bash 中删除主题并删除 tmp 位置中的主题日志

[2018-10-25 10:03:17,919] INFO [Kafka Server 0], started (kafka.server.KafkaServer)
[2018-10-25 10:03:18,080] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions [topic-test,0] (kafka.server.ReplicaFetcherManager)
[2018-10-25 10:03:18,099] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions [topic-test,0] (kafka.server.ReplicaFetcherManager)
[2018-10-25 10:03:48,864] ERROR Processor got uncaught exception. (kafka.network.Processor)
java.lang.ArrayIndexOutOfBoundsException: 18
    at org.apache.kafka.common.protocol.ApiKeys.forId(ApiKeys.java:68)
    at org.apache.kafka.common.requests.AbstractRequest.getRequest(AbstractRequest.java:39)
    at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:79)
    at kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:426)
    at kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:421)
    at scala.collection.Iterator$class.foreach(Iterator.scala:742)
    at scala.collection.AbstractIterator.foreach(Iterator.scala:1194)
    at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
    at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
    at kafka.network.Processor.run(SocketServer.scala:421)
    at java.lang.Thread.run(Thread.java:748)

如果有人能提供深入的见解，以便将来解决类似的其他错误，那将非常有帮助。

【问题讨论】：

您的 Kafka 代理和 Kafka 客户端的版本是什么？
我不确定，但通过谷歌搜索，我能够从路径 /opt/kafka_2 中的机器 kafka_2.11-0.9.0.0.jar 和 kafka-clients-0.9.0.0.jar 中找到它。 11-0.9.0.0/libs
是否可以从我的系统中删除一些元数据文件，从而将其恢复到初始设置？ .因为它曾经与基本的 Bash 生产者和消费者一起工作。
也许你遇到了这个错误？ issues.apache.org/jira/browse/KAFKA-3547
好的，您是否有任何解决方法可以恢复到以前的状态。因为我已经杀死了 kafka 和 zookeeper 并重新启动了同样的问题。

标签： apache-kafka kafka-producer-api

【解决方案1】：

我下载了最新的/kafka_2.11-2.0.0并按照以下步骤操作：

bin/zookeeper-server-start.sh config/zookeeper.properties 
bin/kafka-server-start.sh config/server.properties 
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic-test 
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic-test 
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-test --from-beginning

一切正常。 请注意 --bootstrap-server localhost:9092 已在使用者脚本中更改

【讨论】：