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, getRootCause
public 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.