public interface DeadLetterListener
KinesisRecorderConfig.withDeadLetterListener(DeadLetterListener)
.Modifier and Type | Method and Description |
---|---|
void |
onRecordsDropped(java.lang.String streamName,
java.util.List<byte[]> data)
The data sent here either encountered errors that cannot be retried or exceeded the retry limit.
|
void onRecordsDropped(java.lang.String streamName, java.util.List<byte[]> data)
streamName
- stream the data was being sent to.data
- the list of individual records being submitted represented as a byte array.Copyright © 2018 Amazon Web Services, Inc. All Rights Reserved.