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:
but of course it is preferable to stop the ioThread by cooperation, rather than use the deprecated Thread.stop(new ThreadDeath()).