Class CustomKafkaConsumer.KafkaMessageProcessor

java.lang.Object

org.chenile.pubsub.kafka.configuration.CustomKafkaConsumer.KafkaMessageProcessor

Enclosing class:

CustomKafkaConsumer

static class CustomKafkaConsumer.KafkaMessageProcessor
extends Object

Processor class for handling Kafka messages.

Field Summary

Fields

Modifier and Type	Field	Description
private final EventProcessor	eventProcessor

Constructor Summary

Constructors

Constructor	Description
KafkaMessageProcessor(EventProcessor eventProcessor)

Method Summary

Modifier and Type	Method	Description
void	handleMessage(org.apache.kafka.clients.consumer.ConsumerRecord<String,Object> record)
(package private) static Map<String,String>	headersToMap(org.apache.kafka.common.header.Headers headers)

Methods inherited from class Object

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

Field Details

eventProcessor

private final EventProcessor eventProcessor

Constructor Details

KafkaMessageProcessor

public KafkaMessageProcessor(EventProcessor eventProcessor)

Method Details

handleMessage

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

headersToMap

static Map<String,String> headersToMap(org.apache.kafka.common.header.Headers headers)