[KAFKA-6812] Async ConsoleProducer exits with 0 status even after data loss

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.1.0
• Component/s: tools
• Assignee: Kamal Kang
• Reporter: Andras Beni
• Created: 21/Apr/18 14:44
• Updated: 17/Dec/18 15:06

Description

When ConsoleProducer is run without --sync flag and one of the batches times out, ErrorLoggingCallback logs the error:

 18/04/21 04:23:01 WARN clients.NetworkClient: [Producer clientId=console-producer] Connection to node 10 could not be established. Broker may not be available.
 18/04/21 04:23:02 ERROR internals.ErrorLoggingCallback: Error when sending message to topic my-topic with key: null, value: 8 bytes with error:
 org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for my-topic-0: 1530 ms has passed since batch creation plus linger time

However, the tool exits with status code 0. 
In my opinion the tool should indicate in the exit status that there was data lost. Maybe it's reasonable to exit after the first error.