Class AssigningSubscriber (1.13.6)

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
Name Description
subscriberFactory PartitionSubscriberFactory
reassignmentHandler ReassignmentHandler
assignerFactory AssignerFactory

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
Name Description
error CheckedApiException
Overrides

stop()

protected synchronized void stop()
Overrides