Class ProducerFencedException

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.apache.kafka.common.KafkaException
org.apache.kafka.common.errors.ApiException
org.apache.kafka.common.errors.ApplicationRecoverableException
org.apache.kafka.common.errors.ProducerFencedException
All Implemented Interfaces:
Serializable
public class ProducerFencedExceptionextends ApplicationRecoverableException
This fatal exception indicates that another producer with the same transactional.id has been started. It is only possible to have one producer instance with a transactional.id at any given time, and the latest one to be started "fences" the previous instances so that they can no longer make transactional requests. When you encounter this exception, you must close the producer instance.
See Also:

  • Constructor Details

    • ProducerFencedException

      public ProducerFencedException(String msg)