@Internal public class PollingRecordPublisherFactory extends Object implements RecordPublisherFactory
RecordPublisher
factory used to create instances of PollingRecordPublisher
.Constructor and Description |
---|
PollingRecordPublisherFactory(KinesisDataFetcher.FlinkKinesisProxyFactory kinesisProxyFactory) |
Modifier and Type | Method and Description |
---|---|
PollingRecordPublisher |
create(StartingPosition startingPosition,
Properties consumerConfig,
MetricGroup metricGroup,
StreamShardHandle streamShardHandle)
Create a
PollingRecordPublisher . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public PollingRecordPublisherFactory(KinesisDataFetcher.FlinkKinesisProxyFactory kinesisProxyFactory)
public PollingRecordPublisher create(StartingPosition startingPosition, Properties consumerConfig, MetricGroup metricGroup, StreamShardHandle streamShardHandle) throws InterruptedException
PollingRecordPublisher
. An AdaptivePollingRecordPublisher
will be
created should adaptive reads be enabled in the configuration.create
in interface RecordPublisherFactory
startingPosition
- the position in the shard to start consuming records fromconsumerConfig
- the consumer configuration propertiesmetricGroup
- the metric group to report metrics tostreamShardHandle
- the shard this consumer is subscribed toPollingRecordPublisher
InterruptedException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.