You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Jose Armando Garcia Sancio (Jira)" <ji...@apache.org> on 2019/11/25 18:03:00 UTC
[jira] [Assigned] (KAFKA-9229) initTransactions() fails when
running new producer against an old server
[ https://issues.apache.org/jira/browse/KAFKA-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jose Armando Garcia Sancio reassigned KAFKA-9229:
-------------------------------------------------
Assignee: Jose Armando Garcia Sancio
> 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: Jose Armando Garcia Sancio
> 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 [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)