[KAFKA-1934] Add a shutdownNow() call to new producer

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 08/Feb/15 22:27
• Updated: 09/Feb/15 01:30
• Resolved: 09/Feb/15 01:30

Description

We have a use case where user want to stop send any more messages if an error occurred on a previous send. Otherwise the message order might be broken. The shutdownNow() call will stop the producer right away without draining the messages in accumulator.

Issue Links

• duplicates: KAFKA-1660 Ability to call close() with a timeout on the Java Kafka Producer.