Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout | |
org.apache.flink.streaming.connectors.kinesis.proxy |
Constructor and Description |
---|
FanOutRecordPublisher(StartingPosition startingPosition,
String consumerArn,
StreamShardHandle subscribedShard,
KinesisProxyV2Interface kinesisProxy,
FanOutRecordPublisherConfiguration configuration,
FullJitterBackoff backoff,
java.util.function.Supplier<Boolean> runningSupplier)
Instantiate a new FanOutRecordPublisher.
|
StreamConsumerRegistrar(KinesisProxyV2Interface kinesisProxyV2Interface,
FanOutRecordPublisherConfiguration configuration,
FullJitterBackoff backoff) |
Constructor and Description |
---|
KinesisProxyV2(software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisAsyncClient,
software.amazon.awssdk.http.async.SdkAsyncHttpClient httpClient,
FanOutRecordPublisherConfiguration fanOutRecordPublisherConfiguration,
FullJitterBackoff backoff)
Create a new KinesisProxyV2.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.