Class PushReplicationStartedException

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.PushReplicationStartedException
All Implemented Interfaces:
Serializable
public class PushReplicationStartedExceptionextends ApiException
This exception may be returned by leader in the fetch response, which indicates that the leader has switched to the push replication mode for the partition
See Also:

  • Constructor Details

    • PushReplicationStartedException

      public PushReplicationStartedException(String message)

    • PushReplicationStartedException

      public PushReplicationStartedException(String message, Throwable cause)