Class InvalidProducerEpochException

All Implemented Interfaces:

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:
  • Constructor Details

    • InvalidProducerEpochException

      public InvalidProducerEpochException(String message)