Package org.apache.kafka.common.errors

Class NotCoordinatorException

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.NotCoordinatorException
All Implemented Interfaces:
Serializable
public class NotCoordinatorExceptionextends RetriableException
In the context of the group coordinator, the broker returns this error code if it receives an offset fetch or commit request for a group it's not the coordinator of. In the context of the transactional coordinator, it returns this error when it receives a transactional request with a transactionalId the coordinator doesn't own.
See Also:

  • Constructor Details

    • NotCoordinatorException

      public NotCoordinatorException(String message)

    • NotCoordinatorException

      public NotCoordinatorException(String message, Throwable cause)