Class InvalidProducerEpochException

  • All Implemented Interfaces:
    Serializable

    public class InvalidProducerEpochException
    extends ApiException
    This exception indicates that the produce request sent to the partition leader contains a non-matching producer epoch. When encountering this exception, user should abort the ongoing transaction by calling KafkaProducer#abortTransaction which would try to send initPidRequest and reinitialize the producer under the hood.
    See Also:
    Serialized Form
    • Constructor Detail

      • InvalidProducerEpochException

        public InvalidProducerEpochException​(String message)