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<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>

@Singleton
public class BatchConsumerRecordsBinderRegistry
extends java.lang.Object
implements io.micronaut.core.bind.ArgumentBinderRegistry<org.apache.kafka.clients.consumer.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> java.util.Optional<io.micronaut.core.bind.ArgumentBinder<T,org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>>	findArgumentBinder(io.micronaut.core.type.Argument<T> argument, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> source)

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> java.util.Optional<io.micronaut.core.bind.ArgumentBinder<T,org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>> findArgumentBinder(io.micronaut.core.type.Argument<T> argument,
                                                                                                                                                  org.apache.kafka.clients.consumer.ConsumerRecords<?,?> source)

Specified by:

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