Class AssigningSubscriber

public class AssigningSubscriber extends ProxyService implements Subscriber

Inheritance

java.lang.Object > AbstractApiService > ProxyService > AssigningSubscriber

Implements

Subscriber

Constructors

AssigningSubscriber(PartitionSubscriberFactory subscriberFactory, ReassignmentHandler reassignmentHandler, AssignerFactory assignerFactory)

public AssigningSubscriber(PartitionSubscriberFactory subscriberFactory, ReassignmentHandler reassignmentHandler, AssignerFactory assignerFactory)
Parameters
NameDescription
subscriberFactoryPartitionSubscriberFactory
reassignmentHandlerReassignmentHandler
assignerFactoryAssignerFactory

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
NameDescription
errorCheckedApiException
Overrides

stop()

protected synchronized void stop()
Overrides