[KAFKA-1659] Ability to cleanly abort the KafkaProducer

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.8.2.0
• Component/s: clients, producer
• Assignee: Jun Rao
• Reporter: Andrew Stein
• Created: 30/Sep/14 14:32
• Updated: 19/Aug/15 15:38

Description

I would like the ability to "abort" the Java Client's KafkaProducer. This includes the stopping the writing of buffered records.

The motivation for this is described here.

A sketch of this method is:

public void abort() {
        try {
            ioThread.interrupt();
            ioThread.stop(new ThreadDeath());
        } catch (IllegalAccessException e) {
        }
}

but of course it is preferable to stop the ioThread by cooperation, rather than use the deprecated Thread.stop(new ThreadDeath()).