Class CustomKafkaConsumer

java.lang.Object

org.chenile.pubsub.kafka.configuration.CustomKafkaConsumer

All Implemented Interfaces:

EventListener, ApplicationListener<org.springframework.boot.context.event.ApplicationReadyEvent>, Ordered

@Component
public class CustomKafkaConsumer
extends Object
implements ApplicationListener<org.springframework.boot.context.event.ApplicationReadyEvent>, Ordered

Dynamically registers Kafka listener for all topics defined in Chenile configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	CustomKafkaConsumer.KafkaMessageProcessor	Processor class for handling Kafka messages.

Field Summary

Fields

Modifier and Type	Field	Description
private ChenileConfiguration	chenileConfig
private EventProcessor	eventProcessor
private org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,String>	factory
private static final org.slf4j.Logger	logger
private org.springframework.kafka.config.KafkaListenerEndpointRegistry	registry

Fields inherited from interface Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
CustomKafkaConsumer()

Method Summary

Modifier and Type	Method	Description
int	getOrder()
void	onApplicationEvent(org.springframework.boot.context.event.ApplicationReadyEvent event)	Registers a dynamic Kafka listener after application startup.

Methods inherited from class Object

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

Methods inherited from interface ApplicationListener

supportsAsyncExecution

Field Details

logger

private static final org.slf4j.Logger logger

registry

@Autowired
private org.springframework.kafka.config.KafkaListenerEndpointRegistry registry

factory

@Autowired
private org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,String> factory

chenileConfig

@Autowired
@Qualifier("chenileServiceConfiguration")
private ChenileConfiguration chenileConfig

eventProcessor

@Autowired
private EventProcessor eventProcessor

Constructor Details

CustomKafkaConsumer

public CustomKafkaConsumer()

Method Details

onApplicationEvent

public void onApplicationEvent(org.springframework.boot.context.event.ApplicationReadyEvent event)

Registers a dynamic Kafka listener after application startup.

Specified by:

onApplicationEvent in interface ApplicationListener<org.springframework.boot.context.event.ApplicationReadyEvent>

getOrder

public int getOrder()

Specified by:

getOrder in interface Ordered