[jira] [Resolved] (KAFKA-2750) Sender.java: handleProduceResponse does not check protocol version

["Manikumar (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Manikumar resolved KAFKA-2750.
------------------------------
    Resolution: Fixed

This was fixed in KAFKA-4462 /KIP-97 for newer clients

> Sender.java: handleProduceResponse does not check protocol version
> ------------------------------------------------------------------
>
>                 Key: KAFKA-2750
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2750
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.10.1.0
>            Reporter: Geoff Anderson
>
> If you try run an 0.9 producer against 0.8.2.2 kafka broker, you get a fairly cryptic error message:
> [2015-11-04 18:55:43,583] ERROR Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender)
> org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'throttle_time_ms': java.nio.BufferUnderflowException
> 	at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
> 	at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:462)
> 	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:279)
> 	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:216)
> 	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:141)
> Although we shouldn't expect an 0.9 producer to work against an 0.8.X broker since the protocol version has been increased, perhaps the error could be clearer.
> The cause seems to be that in Sender.java, handleProduceResponse does not to have any mechanism for checking the protocol version of the received produce response - it just calls a constructor which blindly tries to grab the throttle time field which in this case fails.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)