public class KafkaListenerException extends MessageListenerException
ConsumerRecord
via a KafkaListener
.Constructor and Description |
---|
KafkaListenerException(String message,
Object listener,
KafkaConsumer<?,?> kafkaConsumer,
ConsumerRecord<?,?> consumerRecord)
Creates a new exception.
|
KafkaListenerException(String message,
Throwable cause,
Object listener,
KafkaConsumer<?,?> kafkaConsumer,
ConsumerRecord<?,?> consumerRecord)
Creates a new exception.
|
KafkaListenerException(Throwable cause,
Object listener,
KafkaConsumer<?,?> kafkaConsumer,
ConsumerRecord<?,?> consumerRecord)
Creates a new exception.
|
Modifier and Type | Method and Description |
---|---|
Optional<ConsumerRecord<?,?>> |
getConsumerRecord() |
KafkaConsumer<?,?> |
getKafkaConsumer() |
Object |
getKafkaListener() |
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
public KafkaListenerException(String message, Object listener, KafkaConsumer<?,?> kafkaConsumer, ConsumerRecord<?,?> consumerRecord)
message
- The messagelistener
- The listenerkafkaConsumer
- The consumerconsumerRecord
- The consumer recordpublic KafkaListenerException(String message, Throwable cause, Object listener, KafkaConsumer<?,?> kafkaConsumer, ConsumerRecord<?,?> consumerRecord)
message
- The messagecause
- The causelistener
- The listenerkafkaConsumer
- The consumerconsumerRecord
- The consumer recordpublic KafkaListenerException(Throwable cause, Object listener, KafkaConsumer<?,?> kafkaConsumer, ConsumerRecord<?,?> consumerRecord)
cause
- The causelistener
- The listenerkafkaConsumer
- The consumerconsumerRecord
- The consumer recordpublic Object getKafkaListener()
public KafkaConsumer<?,?> getKafkaConsumer()
public Optional<ConsumerRecord<?,?>> getConsumerRecord()