I often see the following exception while running some tests
(ProducerFailureHandlingTest.testNoResponse is one such instance):
Looking at that code in question, I can see that the NPE can be triggered
when the "receive" is null which can happen if the "isRunning" is false
(i.e a shutdown has been requested).