public class KafkaListenerException
extends io.micronaut.messaging.exceptions.MessageListenerException
ConsumerRecord
via a KafkaListener
.Constructor and Description |
---|
KafkaListenerException(java.lang.String message,
java.lang.Object listener,
org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)
Creates a new exception.
|
KafkaListenerException(java.lang.String message,
java.lang.Throwable cause,
java.lang.Object listener,
org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)
Creates a new exception.
|
KafkaListenerException(java.lang.Throwable cause,
java.lang.Object listener,
org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)
Creates a new exception.
|
Modifier and Type | Method and Description |
---|---|
java.util.Optional<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> |
getConsumerRecord() |
org.apache.kafka.clients.consumer.Consumer<?,?> |
getKafkaConsumer() |
java.lang.Object |
getKafkaListener() |
public KafkaListenerException(java.lang.String message, java.lang.Object listener, org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)
message
- The messagelistener
- The listenerkafkaConsumer
- The consumerconsumerRecord
- The consumer recordpublic KafkaListenerException(java.lang.String message, java.lang.Throwable cause, java.lang.Object listener, org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)
message
- The messagecause
- The causelistener
- The listenerkafkaConsumer
- The consumerconsumerRecord
- The consumer recordpublic KafkaListenerException(java.lang.Throwable cause, java.lang.Object listener, org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord)
cause
- The causelistener
- The listenerkafkaConsumer
- The consumerconsumerRecord
- The consumer recordpublic java.lang.Object getKafkaListener()
public org.apache.kafka.clients.consumer.Consumer<?,?> getKafkaConsumer()
public java.util.Optional<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> getConsumerRecord()