public final class KinesisConsumerDestination extends Object implements org.springframework.cloud.stream.provisioning.ConsumerDestination
ConsumerDestination
implementation.Constructor and Description |
---|
KinesisConsumerDestination(String streamName,
List<com.amazonaws.services.kinesis.model.Shard> shards) |
KinesisConsumerDestination(String streamName,
List<com.amazonaws.services.kinesis.model.Shard> shards,
String dlqName) |
Modifier and Type | Method and Description |
---|---|
String |
getName() |
List<com.amazonaws.services.kinesis.model.Shard> |
getShards() |
String |
toString() |
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.