public class BatchListenerFailedException extends KafkaException
KafkaException.Level| Constructor and Description |
|---|
BatchListenerFailedException(java.lang.String message,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
Construct an instance with the provided properties.
|
BatchListenerFailedException(java.lang.String message,
int index)
Construct an instance with the provided properties.
|
BatchListenerFailedException(java.lang.String message,
java.lang.Throwable cause,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
Construct an instance with the provided properties.
|
BatchListenerFailedException(java.lang.String message,
java.lang.Throwable cause,
int index)
Construct an instance with the provided properties.
|
| Modifier and Type | Method and Description |
|---|---|
int |
getIndex()
Return the index in the batch of the failed record.
|
java.lang.String |
getMessage() |
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> |
getRecord()
Return the failed record.
|
selfLogcontains, getMostSpecificCause, getRootCausepublic BatchListenerFailedException(java.lang.String message,
int index)
message - the message.index - the index in the batch of the failed record.public BatchListenerFailedException(java.lang.String message,
@Nullable
java.lang.Throwable cause,
int index)
message - the message.cause - the cause.index - the index in the batch of the failed record.public BatchListenerFailedException(java.lang.String message,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
message - the message.record - the failed record.public BatchListenerFailedException(java.lang.String message,
@Nullable
java.lang.Throwable cause,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
message - the message.cause - the cause.record - the failed record.@Nullable public org.apache.kafka.clients.consumer.ConsumerRecord<?,?> getRecord()
public int getIndex()
public java.lang.String getMessage()
getMessage in class org.springframework.core.NestedRuntimeException