org.apache.kafka.common.errors

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 PushReplicationStartedException
extends 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:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PushReplicationStartedException(String message)
PushReplicationStartedException(String message, Throwable cause)

Method Summary

Methods inherited from class org.apache.kafka.common.errors.ApiException

fillInStackTrace

Methods inherited from class java.lang.Throwable

addSuppressed, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PushReplicationStartedException

public PushReplicationStartedException(String message)

PushReplicationStartedException

public PushReplicationStartedException(String message,
                                       Throwable cause)