Interface PartitionPublisherFactory (1.12.22)

public interface PartitionPublisherFactory extends AutoCloseable

Implements

AutoCloseable

Methods

close()

public abstract void close()

newPublisher(Partition partition)

public abstract Publisher<MessageMetadata> newPublisher(Partition partition)
Parameter
NameDescription
partitionPartition
Returns
TypeDescription
Publisher<MessageMetadata>
Exceptions
TypeDescription
ApiException