Interface PartitionPublisherFactory (1.14.8)

public interface PartitionPublisherFactory extends AutoCloseable

Implements

AutoCloseable

Methods

close()

public abstract void close()

newPublisher(Partition partition)

public abstract Publisher<MessageMetadata> newPublisher(Partition partition)
Parameter
Name Description
partition Partition
Returns
Type Description
Publisher<MessageMetadata>
Exceptions
Type Description
ApiException