Package io.micronaut.configuration.kafka.bind.batch

Class BatchConsumerRecordsBinderRegistry

java.lang.Object

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

All Implemented Interfaces:

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

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

Binds arguments in batches from a ConsumerRecords instance.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor	Description
BatchConsumerRecordsBinderRegistry(ConsumerRecordBinderRegistry consumerRecordBinderRegistry, io.micronaut.core.convert.ConversionService conversionService)	Constructs a new instance.

Method Summary

Modifier and Type	Method	Description
<T> Optional<io.micronaut.core.bind.ArgumentBinder<T,ConsumerRecords<?,?>>>	findArgumentBinder(io.micronaut.core.type.Argument<T> argument, ConsumerRecords<?,?> 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

BatchConsumerRecordsBinderRegistry

public BatchConsumerRecordsBinderRegistry(ConsumerRecordBinderRegistry consumerRecordBinderRegistry,
 io.micronaut.core.convert.ConversionService conversionService)

Constructs a new instance.

Parameters:

consumerRecordBinderRegistry - The wrapped ConsumerRecordBinderRegistry

conversionService - The conversion service

Method Details

findArgumentBinder

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

Specified by:

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