Modifier and Type | Method and Description |
---|---|
KinesisProxyV2Interface |
KinesisDataFetcher.FlinkKinesisProxyV2Factory.create(Properties configProps) |
Constructor and Description |
---|
FanOutRecordPublisher(StartingPosition startingPosition,
String consumerArn,
StreamShardHandle subscribedShard,
KinesisProxyV2Interface kinesisProxy,
FanOutRecordPublisherConfiguration configuration,
FullJitterBackoff backoff)
Instantiate a new FanOutRecordPublisher.
|
FanOutRecordPublisherFactory(KinesisProxyV2Interface kinesisProxy)
Instantiate a factory responsible for creating
FanOutRecordPublisher . |
StreamConsumerRegistrar(KinesisProxyV2Interface kinesisProxyV2Interface,
FanOutRecordPublisherConfiguration configuration,
FullJitterBackoff backoff) |
Modifier and Type | Class and Description |
---|---|
class |
KinesisProxyV2
Kinesis proxy implementation using AWS SDK v2.x - a utility class that is used as a proxy to make
calls to AWS Kinesis for several EFO (Enhanced Fan Out) functions, such as de-/registering stream
consumers, subscribing to a shard and receiving records from a shard.
|
Modifier and Type | Method and Description |
---|---|
static KinesisProxyV2Interface |
KinesisProxyV2Factory.createKinesisProxyV2(Properties configProps)
Uses the given properties to instantiate a new instance of
KinesisProxyV2 . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.