io.micronaut.configuration.kafka.bind

Class KafkaDefaultBinder<T>

java.lang.Object

io.micronaut.configuration.kafka.bind.KafkaDefaultBinder<T>

Type Parameters:

T - The target generic type

All Implemented Interfaces:

ConsumerRecordBinder<T>, ArgumentBinder<T,ConsumerRecord<?,?>>

public class KafkaDefaultBinder<T>
extends Object
implements ConsumerRecordBinder<T>

The default binder that binds the Kafka value for a ConsumerRecord.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested classes/interfaces inherited from interface io.micronaut.core.bind.ArgumentBinder

ArgumentBinder.BindingResult<T>

Constructor Summary

Constructors

Constructor and Description
KafkaDefaultBinder() Default constructor.

Method Summary

Modifier and Type	Method and Description
ArgumentBinder.BindingResult<T>	bind(ArgumentConversionContext<T> context, ConsumerRecord<?,?> source) Bind the given argument from the given source.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaDefaultBinder

public KafkaDefaultBinder()

Default constructor.

Method Detail

bind

public ArgumentBinder.BindingResult<T> bind(ArgumentConversionContext<T> context,
                                            ConsumerRecord<?,?> source)

Description copied from interface: ArgumentBinder

Bind the given argument from the given source.

Specified by:

bind in interface ArgumentBinder<T,ConsumerRecord<?,?>>

Parameters:

context - The ArgumentConversionContext

source - The source

Returns:

An Optional of the value. If no binding was possible Optional.empty()