AtomicReference<KafkaException> sendException() {
        return sendException;
    }
@throws IllegalStateException if EOS is disabled
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java