io.micronaut.configuration.kafka.exceptions

Class KafkaListenerException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.micronaut.messaging.exceptions.MessagingException

io.micronaut.messaging.exceptions.MessageListenerException

io.micronaut.configuration.kafka.exceptions.KafkaListenerException

All Implemented Interfaces:

Serializable

public class KafkaListenerException
extends MessageListenerException

Exception thrown when an error occurs processing a ConsumerRecord via a KafkaListener.

Since:

1.0

Author:

Graeme Rocher

See Also:

Serialized Form

Constructor Summary

Constructors

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.

Method Summary

Modifier and Type	Method and Description
Optional<ConsumerRecord<?,?>>	getConsumerRecord()
KafkaConsumer<?,?>	getKafkaConsumer()
Object	getKafkaListener()

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaListenerException

public KafkaListenerException(String message,
                              Object listener,
                              KafkaConsumer<?,?> kafkaConsumer,
                              ConsumerRecord<?,?> consumerRecord)

Creates a new exception.

Parameters:

message - The message

listener - The listener

kafkaConsumer - The consumer

consumerRecord - The consumer record

KafkaListenerException

public KafkaListenerException(String message,
                              Throwable cause,
                              Object listener,
                              KafkaConsumer<?,?> kafkaConsumer,
                              ConsumerRecord<?,?> consumerRecord)

Creates a new exception.

Parameters:

message - The message

cause - The cause

listener - The listener

kafkaConsumer - The consumer

consumerRecord - The consumer record

KafkaListenerException

public KafkaListenerException(Throwable cause,
                              Object listener,
                              KafkaConsumer<?,?> kafkaConsumer,
                              ConsumerRecord<?,?> consumerRecord)

Creates a new exception.

Parameters:

cause - The cause

listener - The listener

kafkaConsumer - The consumer

consumerRecord - The consumer record

Method Detail

getKafkaListener

public Object getKafkaListener()

Returns:

The bean that is the kafka listener

getKafkaConsumer

public KafkaConsumer<?,?> getKafkaConsumer()

Returns:

The consumer that produced the error

getConsumerRecord

public Optional<ConsumerRecord<?,?>> getConsumerRecord()

Returns:

The consumer record that was being processed that caused the error