Ask Your Question

Revision history [back]

click to hide/show revision 1
initial version

What can be done when multiple Kafka Producers are used to send the same producerRecord, but encounter a java.lang.IllegalStateException due to the closing of RecordHeaders?