Kafka生产消息出现java.lang.ArrayIndexOutOfBoundsException: 18的情况

来源：7-10 自定义维护Offset读取实现

BillyWebber

2021-01-02

我在运行ImoocKafkaProducerV2生产消息的时候，Kafka的消息生产的时候出现一个这样的问题，Kafka已创建过my-replicated-topic 这个topic，但是我已将topic删除并重新创建（并且也尝试创建使用其他名字的topic）但Kafka的控制台在生产消息的时候还是报这个错，请问是什么原因呢？

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)
[2021-01-02 17:38:41,489] 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)

写回答

2回答