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)