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

    • InvalidProducerEpochException

      public InvalidProducerEpochException​(String message)