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()).