https://github.com/spring-projects/spring-kafka/blob/master/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java#L201 stop method should change running to false, it's better to use `AtomicBoolean.compareAndSet()` instead of `volatile boolean`