io.micronaut.configuration.kafka.bind

Class KafkaKeyBinder<T>

java.lang.Object

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

Type Parameters:

T - The target type

All Implemented Interfaces:

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

@Singleton
public class KafkaKeyBinder<T>
extends Object
implements AnnotatedConsumerRecordBinder<KafkaKey,T>

Binder for binding the parameters that is designated the KafkaKey.

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
KafkaKeyBinder()

Method Summary

Modifier and Type	Method and Description
Class<KafkaKey>	annotationType()
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

KafkaKeyBinder

public KafkaKeyBinder()

Method Detail

annotationType

public Class<KafkaKey> annotationType()

Specified by:

annotationType in interface AnnotatedConsumerRecordBinder<KafkaKey,T>

Returns:

The annotation type

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()