[
https://issues.apache.org/jira/browse/KAFKA-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhang updated KAFKA-9229:
--------------------------------
Description:
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]
was:
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]
> 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)
