io.smallrye.reactive.messaging.kafka.fault

Class KafkaDeadLetterQueue

java.lang.Object

io.smallrye.reactive.messaging.kafka.fault.KafkaDeadLetterQueue

All Implemented Interfaces:

KafkaFailureHandler

public class KafkaDeadLetterQueue
extends Object
implements KafkaFailureHandler

Nested Class Summary

Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.kafka.fault.KafkaFailureHandler

KafkaFailureHandler.Strategy

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEAD_LETTER_CAUSE
static String	DEAD_LETTER_OFFSET
static String	DEAD_LETTER_PARTITION
static String	DEAD_LETTER_REASON
static String	DEAD_LETTER_TOPIC

Constructor Summary

Constructors

Constructor and Description
KafkaDeadLetterQueue(String channel, String topic, ReactiveKafkaProducer producer, KafkaSource<?,?> source)

Method Summary

Modifier and Type	Method and Description
static KafkaFailureHandler	create(Map<String,?> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source, KafkaCDIEvents kafkaCDIEvents)
<K,V> CompletionStage<Void>	handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)
void	terminate()

Methods inherited from class java.lang.Object

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

Field Detail

DEAD_LETTER_REASON

public static final String DEAD_LETTER_REASON

See Also:

Constant Field Values

DEAD_LETTER_CAUSE

public static final String DEAD_LETTER_CAUSE

See Also:

Constant Field Values

DEAD_LETTER_TOPIC

public static final String DEAD_LETTER_TOPIC

See Also:

Constant Field Values

DEAD_LETTER_OFFSET

public static final String DEAD_LETTER_OFFSET

See Also:

Constant Field Values

DEAD_LETTER_PARTITION

public static final String DEAD_LETTER_PARTITION

See Also:

Constant Field Values

Constructor Detail

KafkaDeadLetterQueue

public KafkaDeadLetterQueue(String channel,
                            String topic,
                            ReactiveKafkaProducer producer,
                            KafkaSource<?,?> source)

Method Detail

create

public static KafkaFailureHandler create(Map<String,?> kafkaConfiguration,
                                         KafkaConnectorIncomingConfiguration conf,
                                         KafkaSource<?,?> source,
                                         KafkaCDIEvents kafkaCDIEvents)

handle

public <K,V> CompletionStage<Void> handle(IncomingKafkaRecord<K,V> record,
                                          Throwable reason,
                                          Metadata metadata)

Specified by:

handle in interface KafkaFailureHandler

terminate

public void terminate()

Specified by:

terminate in interface KafkaFailureHandler