Package io.micronaut.configuration.kafka.bind

Class ConsumerRecordBinderRegistry

java.lang.Object

io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry

All Implemented Interfaces:

io.micronaut.core.bind.ArgumentBinderRegistry<ConsumerRecord<?,?>>

@Singleton
public class ConsumerRecordBinderRegistry
extends Object
implements io.micronaut.core.bind.ArgumentBinderRegistry<ConsumerRecord<?,?>>

A registry of ConsumerRecordBinder.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor	Description
ConsumerRecordBinderRegistry(ConsumerRecordBinder<?>... binders)	Deprecated. Use conversion service constructor instead.
ConsumerRecordBinderRegistry(io.micronaut.core.convert.ConversionService conversionService, ConsumerRecordBinder<?>... binders)	Creates the registry for the given binders.

Method Summary

Modifier and Type	Method	Description
<T> Optional<io.micronaut.core.bind.ArgumentBinder<T,ConsumerRecord<?,?>>>	findArgumentBinder(io.micronaut.core.type.Argument<T> argument, ConsumerRecord<?,?> source)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.core.bind.ArgumentBinderRegistry

addRequestArgumentBinder

Constructor Details

ConsumerRecordBinderRegistry

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

Deprecated.

Use conversion service constructor instead.

Creates the registry for the given binders.

Parameters:

binders - The binders

ConsumerRecordBinderRegistry

@Inject
public ConsumerRecordBinderRegistry(io.micronaut.core.convert.ConversionService conversionService,
 ConsumerRecordBinder<?>... binders)

Creates the registry for the given binders.

Parameters:

conversionService - The conversion service

binders - The binders

Method Details

findArgumentBinder

public <T>
Optional<io.micronaut.core.bind.ArgumentBinder<T,ConsumerRecord<?,?>>> findArgumentBinder(io.micronaut.core.type.Argument<T> argument,
 ConsumerRecord<?,?> source)

Specified by:

findArgumentBinder in interface io.micronaut.core.bind.ArgumentBinderRegistry<ConsumerRecord<?,?>>