Package com.onec.kafka

Class KafkaEventConsumer

java.lang.Object

com.onec.kafka.KafkaEventConsumer

All Implemented Interfaces:

org.springframework.kafka.listener.GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>>, org.springframework.kafka.listener.MessageListener<String,String>

public class KafkaEventConsumer
extends Object
implements org.springframework.kafka.listener.MessageListener<String,String>

Kafka message listener that decodes the CloudEvents envelope, de-duplicates via the Inbox, and dispatches to application EventHandlers through the InboundEventRouter.

Failures during handling mark the inbox row FAILED and either publish to the configured dead-letter topic (then commit) or rethrow to let the container redeliver.

Constructor Summary

Constructors

Constructor	Description
KafkaEventConsumer(InboundEventRouter router, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Inbox inbox, org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate, OnecKafkaProperties properties)

Method Summary

Modifier and Type	Method	Description
void	onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.kafka.listener.GenericMessageListener

onMessage, onMessage, onMessage

Constructor Details

KafkaEventConsumer

public KafkaEventConsumer(InboundEventRouter router,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 Inbox inbox,
 org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate,
 OnecKafkaProperties properties)

Method Details

onMessage

public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)

Specified by:

onMessage in interface org.springframework.kafka.listener.GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>>