@Internal public interface RecordPublisherFactory
RecordPublisher
.Modifier and Type | Method and Description |
---|---|
default void |
close()
Destroy any open resources used by the factory.
|
RecordPublisher |
create(StartingPosition startingPosition,
Properties consumerConfig,
MetricGroup metricGroup,
StreamShardHandle streamShardHandle)
Create a
RecordPublisher . |
RecordPublisher create(StartingPosition startingPosition, Properties consumerConfig, MetricGroup metricGroup, StreamShardHandle streamShardHandle) throws InterruptedException
RecordPublisher
.startingPosition
- the position in the shard to start consuming records fromconsumerConfig
- the properties used to configure the RecordPublisher
.metricGroup
- the MetricGroup
used to report metrics tostreamShardHandle
- the stream shard in which to consume fromRecordPublisher
InterruptedException
default void close()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.