Cheng Ju created KAFKA-4669:
-------------------------------
Summary: KafkaProducer.flush hangs when
NetworkClient.handleCompletedReceives throws exception
Key: KAFKA-4669
URL: https://issues.apache.org/jira/browse/KAFKA-4669
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 0.9.0.1
Reporter: Cheng Ju
There is no try catch in NetworkClient.handleCompletedReceives. If an
exception is thrown after inFlightRequests.completeNext(source), then the
corresponding RecordBatch's done will never get called, and KafkaProducer.flush
will hang on this RecordBatch.
I've checked 0.10 code and think this bug does exist in 0.10 versions.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
