Class KinesisShardEndedEvent

java.lang.Object
java.util.EventObject
org.springframework.context.ApplicationEvent
org.springframework.integration.events.IntegrationEvent
io.awspring.cloud.kinesis.integration.KinesisShardEndedEvent
All Implemented Interfaces:
Serializable

public class KinesisShardEndedEvent extends org.springframework.integration.events.IntegrationEvent
An event emitted when shard is closed for consumption.
Since:
4.0
Author:
Artem Bilan
See Also:
  • Constructor Details

    • KinesisShardEndedEvent

      public KinesisShardEndedEvent(Object source, String shardKey)
  • Method Details

    • getShardKey

      public String getShardKey()