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)

Reply via email to