@Internal public class FanOutRecordPublisherFactory extends Object implements RecordPublisherFactory
RecordPublisher
factory used to create instances of FanOutRecordPublisher
.Constructor and Description |
---|
FanOutRecordPublisherFactory(KinesisProxyV2Interface kinesisProxy)
Instantiate a factory responsible for creating
FanOutRecordPublisher . |
Modifier and Type | Method and Description |
---|---|
void |
close()
Destroy any open resources used by the factory.
|
FanOutRecordPublisher |
create(StartingPosition startingPosition,
Properties consumerConfig,
MetricGroup metricGroup,
StreamShardHandle streamShardHandle)
Create a
FanOutRecordPublisher . |
public FanOutRecordPublisherFactory(KinesisProxyV2Interface kinesisProxy)
FanOutRecordPublisher
.kinesisProxy
- the singleton proxy used by all record publishers created by this factorypublic FanOutRecordPublisher create(StartingPosition startingPosition, Properties consumerConfig, MetricGroup metricGroup, StreamShardHandle streamShardHandle)
FanOutRecordPublisher
.create
in interface RecordPublisherFactory
startingPosition
- the starting position in the shard to start consuming fromconsumerConfig
- the consumer configuration propertiesmetricGroup
- the metric group to report metrics tostreamShardHandle
- the shard this consumer is subscribed toFanOutRecordPublisher
public void close()
RecordPublisherFactory
close
in interface RecordPublisherFactory
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.