[
https://issues.apache.org/jira/browse/KAFKA-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9229.
------------------------------------
Resolution: Fixed
> 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
> Assignee: Colin McCabe
> Priority: Major
>
> 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 the AK 2.4 branch.
> 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)
