io.micronaut.configuration.kafka.bind.batch

Class BatchConsumerRecordsBinderRegistry

java.lang.Object

io.micronaut.configuration.kafka.bind.batch.BatchConsumerRecordsBinderRegistry

All Implemented Interfaces:

ArgumentBinderRegistry<ConsumerRecords<?,?>>

@Singleton
public class BatchConsumerRecordsBinderRegistry
extends Object
implements ArgumentBinderRegistry<ConsumerRecords<?,?>>

Binds arguments in batches from a ConsumerRecords instance.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
BatchConsumerRecordsBinderRegistry(ConsumerRecordBinderRegistry consumerRecordBinderRegistry) Constructs a new instance.

Method Summary

Modifier and Type	Method and Description
<T> Optional<ArgumentBinder<T,ConsumerRecords<?,?>>>	findArgumentBinder(Argument<T> argument, ConsumerRecords<?,?> source) Locate an ArgumentBinder for the given argument and source type.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchConsumerRecordsBinderRegistry

public BatchConsumerRecordsBinderRegistry(ConsumerRecordBinderRegistry consumerRecordBinderRegistry)

Constructs a new instance.

Parameters:

consumerRecordBinderRegistry - The wrapped ConsumerRecordBinderRegistry

Method Detail

findArgumentBinder

public <T> Optional<ArgumentBinder<T,ConsumerRecords<?,?>>> findArgumentBinder(Argument<T> argument,
                                                                               ConsumerRecords<?,?> source)

Description copied from interface: ArgumentBinderRegistry

Locate an ArgumentBinder for the given argument and source type.

Specified by:

findArgumentBinder in interface ArgumentBinderRegistry<ConsumerRecords<?,?>>

Type Parameters:

T - The argument type

Parameters:

argument - The argument

source - The source

Returns:

An Optional of ArgumentBinder