[
https://issues.apache.org/jira/browse/KAFKA-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140105#comment-15140105
]
Joel Koshy commented on KAFKA-2750:
-----------------------------------
[~felixgv] You mean retry with the older protocol? It does not do it currently
- i.e., it always sends with the latest version. However, it should be possible
after we support protocol version querying:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-35+-+Retrieving+protocol+version
Until that is available we only recommend upgrading the clients _after_ the
brokers.
> 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.0.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.3.4#6332)
