Class UnknownLeaderEpochException

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.RetriableException
org.apache.kafka.common.errors.UnknownLeaderEpochException
All Implemented Interfaces:
Serializable
public class UnknownLeaderEpochExceptionextends RetriableException
The request contained a leader epoch which is larger than that on the broker that received the request. This can happen if the client observes a metadata update before it has been propagated to all brokers. Clients need not refresh metadata before retrying.
See Also:

  • Constructor Details

    • UnknownLeaderEpochException

      public UnknownLeaderEpochException(String message)

    • UnknownLeaderEpochException

      public UnknownLeaderEpochException(String message, Throwable cause)