Bryan Baugher created KAFKA-3345:
------------------------------------
Summary: ProducerResponse could gracefully handle no throttle time
provided
Key: KAFKA-3345
URL: https://issues.apache.org/jira/browse/KAFKA-3345
Project: Kafka
Issue Type: Improvement
Reporter: Bryan Baugher
Priority: Minor
When doing some compatibility testing between kafka 0.8 and 0.9 I found that
the old producer using 0.9 libraries could write to a cluster running 0.8 if
'request.required.acks' was set to 0. If it was set to anything else it would
fail with,
{code}
java.nio.BufferUnderflowException
at java.nio.Buffer.nextGetIndex(Buffer.java:506)
at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:361)
at kafka.api.ProducerResponse$.readFrom(ProducerResponse.scala:41)
at kafka.producer.SyncProducer.send(SyncProducer.scala:109)
{code}
In 0.9 there was a one line change to the response here[1] to look for a
throttle time value in the response. It seems if the 0.9 code gracefully
handled throttle time not being provided this would work. Would you be open to
this change?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
