io.micronaut.configuration.kafka.bind

Class ConsumerRecordBinderRegistry

java.lang.Object

io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry

All Implemented Interfaces:

io.micronaut.core.bind.ArgumentBinderRegistry<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>

@Singleton
public class ConsumerRecordBinderRegistry
extends java.lang.Object
implements io.micronaut.core.bind.ArgumentBinderRegistry<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>

A registry of ConsumerRecordBinder.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
ConsumerRecordBinderRegistry(ConsumerRecordBinder<?>... binders) Creates the registry for the given binders.

Method Summary

Modifier and Type	Method and Description
<T> java.util.Optional<io.micronaut.core.bind.ArgumentBinder<T,org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>>	findArgumentBinder(io.micronaut.core.type.Argument<T> argument, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> source)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecordBinderRegistry

public ConsumerRecordBinderRegistry(ConsumerRecordBinder<?>... binders)

Creates the registry for the given binders.

Parameters:

binders - The binders

Method Detail

findArgumentBinder

public <T> java.util.Optional<io.micronaut.core.bind.ArgumentBinder<T,org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>> findArgumentBinder(io.micronaut.core.type.Argument<T> argument,
                                                                                                                                                 org.apache.kafka.clients.consumer.ConsumerRecord<?,?> source)

Specified by:

findArgumentBinder in interface io.micronaut.core.bind.ArgumentBinderRegistry<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>