Class KplBackpressureException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.awspring.cloud.kinesis.integration.KplBackpressureException

All Implemented Interfaces:

Serializable

public class KplBackpressureException
extends RuntimeException

An exception triggered from the KplMessageHandler while sending records to Kinesis when maximum number of records in flight exceeds the backpressure threshold.

Since:

4.0

Author:

Siddharth Jain, Artem Bilan

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
KplBackpressureException(String message, software.amazon.kinesis.producer.UserRecord userRecord)

Method Summary

Modifier and Type	Method	Description
software.amazon.kinesis.producer.UserRecord	getUserRecord()	Get the UserRecord when this exception has been thrown.

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

KplBackpressureException

public KplBackpressureException(String message,
 software.amazon.kinesis.producer.UserRecord userRecord)

Method Details

getUserRecord

public software.amazon.kinesis.producer.UserRecord getUserRecord()

Get the UserRecord when this exception has been thrown.

Returns:

the UserRecord when this exception has been thrown.