Interface PartitionSubscriberFactory (1.12.2)

public interface PartitionSubscriberFactory extends AutoCloseable

PartitionSubscriberFactories are used dynamically in a context where there is no client downcall. Therefore, their factory method throws a checked exception.

Implements

AutoCloseable

Methods

close()

public abstract void close()

newSubscriber(Partition partition)

public abstract Subscriber newSubscriber(Partition partition)
Parameter
NameDescription
partitionPartition
Returns
TypeDescription
Subscriber
Exceptions
TypeDescription
CheckedApiException