Steven Zhang created KAFKA-9229:
-----------------------------------
Summary: initTransactions() fails when running new producer
against an old server
Key: KAFKA-9229
URL: https://issues.apache.org/jira/browse/KAFKA-9229
Project: Kafka
Issue Type: Bug
Reporter: Steven Zhang
When using transactions to produce to a topic, I'm encountering this error when
I try to initTransactions()
{code:java}
[2019-11-22 09:32:39,076] ERROR Closing socket for
10.200.24.250:9092-10.200.24.250:55885-63 because of error
(kafka.network.Processor)org.apache.kafka.common.errors.InvalidRequestException:
Error getting request for apiKey: INIT_PRODUCER_ID, apiVersion: 2,
connectionId: 10.200.24.250:9092-10.200.24.250:55885-63, listenerName:
ListenerName(PLAINTEXT), principal: User:ANONYMOUSCaused by:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field
'_tagged_fields': Varint is too long, the most significant bit in the 5th byte
is set, converted value: ffffffff at
org.apache.kafka.common.protocol.types.Schema.read(Schema.java:110) at
org.apache.kafka.common.protocol.ApiKeys.parseRequest(ApiKeys.java:340) at
org.apache.kafka.common.requests.RequestContext.parseRequest(RequestContext.java:65)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:90)
at
kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:931)
at
kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:914)
at scala.collection.Iterator.foreach(Iterator.scala:941) at
scala.collection.Iterator.foreach$(Iterator.scala:941) at
scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at
scala.collection.IterableLike.foreach(IterableLike.scala:74) at
scala.collection.IterableLike.foreach$(IterableLike.scala:73) at
scala.collection.AbstractIterable.foreach(Iterable.scala:56) at
kafka.network.Processor.processCompletedReceives(SocketServer.scala:914) at
kafka.network.Processor.run(SocketServer.scala:804) at
java.lang.Thread.run(Thread.java:748)
{code}
The producer is from the Kafka master branch while the Kafka server is running
from [https://github.com/confluentinc/ce-kafka/tree/5.4.x]
The cause for this appears to be this commit. It should've been modifying
version 3 but version 2 (an already existing version) was modified instead.
[https://github.com/apache/kafka/commit/fecb977b257888e2022c1b1e04dd7bf03e18720c]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
