Package org.apache.kafka.common.errors
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.ProducerFencedException
-
- All Implemented Interfaces:
java.io.Serializable
public class ProducerFencedException extends ApiException
This fatal exception indicates that another producer with the sametransactional.id
has been started. It is only possible to have one producer instance with atransactional.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:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ProducerFencedException(java.lang.String msg)
-
Method Summary
-
Methods inherited from class org.apache.kafka.common.errors.ApiException
fillInStackTrace
-
-