org.apache.flink.streaming.connectors.kinesis.proxy

Interface KinesisProxyV2Interface

All Known Implementing Classes:

KinesisProxyV2

@Internal
public interface KinesisProxyV2Interface

Interface for a Kinesis proxy using AWS SDK v2.x operating on multiple Kinesis streams within the same AWS service region.

Method Summary

Modifier and Type	Method and Description
default void	close() Destroy any open resources used by the factory.
software.amazon.awssdk.services.kinesis.model.DeregisterStreamConsumerResponse	deregisterStreamConsumer(String consumerArn)
software.amazon.awssdk.services.kinesis.model.DescribeStreamConsumerResponse	describeStreamConsumer(String streamConsumerArn)
software.amazon.awssdk.services.kinesis.model.DescribeStreamConsumerResponse	describeStreamConsumer(String streamArn, String consumerName)
software.amazon.awssdk.services.kinesis.model.DescribeStreamSummaryResponse	describeStreamSummary(String stream)
software.amazon.awssdk.services.kinesis.model.RegisterStreamConsumerResponse	registerStreamConsumer(String streamArn, String consumerName)
CompletableFuture<Void>	subscribeToShard(software.amazon.awssdk.services.kinesis.model.SubscribeToShardRequest request, software.amazon.awssdk.services.kinesis.model.SubscribeToShardResponseHandler responseHandler)

Method Detail

describeStreamSummary

software.amazon.awssdk.services.kinesis.model.DescribeStreamSummaryResponse describeStreamSummary(String stream)
                                                                                           throws InterruptedException,
                                                                                                  ExecutionException

Throws:

InterruptedException

ExecutionException

describeStreamConsumer

software.amazon.awssdk.services.kinesis.model.DescribeStreamConsumerResponse describeStreamConsumer(String streamConsumerArn)
                                                                                             throws InterruptedException,
                                                                                                    ExecutionException

Throws:

InterruptedException

ExecutionException

describeStreamConsumer

software.amazon.awssdk.services.kinesis.model.DescribeStreamConsumerResponse describeStreamConsumer(String streamArn,
                                                                                                    String consumerName)
                                                                                             throws InterruptedException,
                                                                                                    ExecutionException

Throws:

InterruptedException

ExecutionException

registerStreamConsumer

software.amazon.awssdk.services.kinesis.model.RegisterStreamConsumerResponse registerStreamConsumer(String streamArn,
                                                                                                    String consumerName)
                                                                                             throws InterruptedException,
                                                                                                    ExecutionException

Throws:

InterruptedException

ExecutionException

deregisterStreamConsumer

software.amazon.awssdk.services.kinesis.model.DeregisterStreamConsumerResponse deregisterStreamConsumer(String consumerArn)
                                                                                                 throws InterruptedException,
                                                                                                        ExecutionException

Throws:

InterruptedException

ExecutionException

subscribeToShard

CompletableFuture<Void> subscribeToShard(software.amazon.awssdk.services.kinesis.model.SubscribeToShardRequest request,
                                         software.amazon.awssdk.services.kinesis.model.SubscribeToShardResponseHandler responseHandler)

close

default void close()

Destroy any open resources used by the factory.