io.micronaut.configuration.kafka.processor

Class KafkaConsumerProcessor

java.lang.Object

io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor

All Implemented Interfaces:

AnnotationProcessor<KafkaListener,ExecutableMethod<?,?>>, ExecutableMethodProcessor<KafkaListener>, AutoCloseable

@Singleton
 @Requires(beans=KafkaDefaultConfiguration.class)
public class KafkaConsumerProcessor
extends Object
implements ExecutableMethodProcessor<KafkaListener>, AutoCloseable

A ExecutableMethodProcessor that will process all beans annotated with KafkaListener and create and subscribe the relevant methods as consumers to Kafka topics.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description

KafkaConsumerProcessor(ExecutorService executorService, ApplicationConfiguration applicationConfiguration, BeanContext beanContext, AbstractKafkaConsumerConfiguration defaultConsumerConfiguration, ConsumerRecordBinderRegistry binderRegistry, BatchConsumerRecordsBinderRegistry batchBinderRegistry, SerdeRegistry serdeRegistry, KafkaProducerRegistry producerRegistry, KafkaListenerExceptionHandler exceptionHandler) Creates a new processor using the given ExecutorService to schedule consumers on.

Method Summary

Modifier and Type	Method and Description
void	close()
void	process(BeanDefinition<?> beanDefinition, ExecutableMethod<?,?> method) The process method will be called for every ExecutableMethod that is annotated with the type parameter A.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConsumerProcessor

public KafkaConsumerProcessor(@Named(value="consumer")
                              ExecutorService executorService,
                              ApplicationConfiguration applicationConfiguration,
                              BeanContext beanContext,
                              AbstractKafkaConsumerConfiguration defaultConsumerConfiguration,
                              ConsumerRecordBinderRegistry binderRegistry,
                              BatchConsumerRecordsBinderRegistry batchBinderRegistry,
                              SerdeRegistry serdeRegistry,
                              KafkaProducerRegistry producerRegistry,
                              KafkaListenerExceptionHandler exceptionHandler)

Creates a new processor using the given ExecutorService to schedule consumers on.

Parameters:

executorService - The executor service

applicationConfiguration - The application configuration

beanContext - The bean context

defaultConsumerConfiguration - The default consumer config

binderRegistry - The ConsumerRecordBinderRegistry

batchBinderRegistry - The BatchConsumerRecordsBinderRegistry

serdeRegistry - The Serde registry

producerRegistry - The KafkaProducerRegistry

exceptionHandler - The exception handler to use

Method Detail

process

public void process(BeanDefinition<?> beanDefinition,
                    ExecutableMethod<?,?> method)

Description copied from interface: ExecutableMethodProcessor

The process method will be called for every ExecutableMethod that is annotated with the type parameter A.

Specified by:

process in interface AnnotationProcessor<KafkaListener,ExecutableMethod<?,?>>

Specified by:

process in interface ExecutableMethodProcessor<KafkaListener>

Parameters:

beanDefinition - The bean definition to process

method - The executable method

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable