public class ListenerExecutionFailedException extends KafkaException
KafkaException extension.| Constructor and Description |
|---|
ListenerExecutionFailedException(java.lang.String message)
Construct an instance with the provided properties.
|
ListenerExecutionFailedException(java.lang.String message,
java.lang.String groupId,
java.lang.Throwable cause)
Construct an instance with the provided properties.
|
ListenerExecutionFailedException(java.lang.String message,
java.lang.Throwable cause)
Construct an instance with the provided properties.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getGroupId()
Return the consumer group.id property of the container that threw this exception.
|
contains, getMessage, getMostSpecificCause, getRootCausepublic ListenerExecutionFailedException(java.lang.String message)
message - the exception message.public ListenerExecutionFailedException(java.lang.String message,
@Nullable
java.lang.Throwable cause)
message - the exception message.cause - the cause.public ListenerExecutionFailedException(java.lang.String message,
@Nullable
java.lang.String groupId,
@Nullable
java.lang.Throwable cause)
message - the exception message.groupId - the container's group.id property.cause - the cause.