MessageProducerSupport
implementation for receiving data from Amazon Kinesis stream(s).AbstractMessageHandler
implementation for the Amazon Kinesis putRecord(s)
.ErrorMessageStrategy
implementation to build an ErrorMessage
with the AwsHeaders.RAW_RECORD
header by the value from
the the provided AttributeAccessor
.ShardIteratorType
.