io.micronaut.configuration.kafka.bind

Class KafkaHeadersBinder

java.lang.Object

io.micronaut.configuration.kafka.bind.KafkaHeadersBinder

All Implemented Interfaces:

ConsumerRecordBinder<MessageHeaders>, TypedConsumerRecordBinder<MessageHeaders>, ArgumentBinder<MessageHeaders,ConsumerRecord<?,?>>, TypeArgumentBinder<MessageHeaders,ConsumerRecord<?,?>>

@Singleton
public class KafkaHeadersBinder
extends Object
implements TypedConsumerRecordBinder<MessageHeaders>

Obtains the MessageHeaders object for Kafka.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

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

ArgumentBinder.BindingResult<T>

Field Summary

Fields

Modifier and Type	Field and Description
static Argument<MessageHeaders>	TYPE

Constructor Summary

Constructors

Constructor and Description
KafkaHeadersBinder()

Method Summary

Modifier and Type	Method and Description
Argument<MessageHeaders>	argumentType()
ArgumentBinder.BindingResult<MessageHeaders>	bind(ArgumentConversionContext<MessageHeaders> 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

Field Detail

TYPE

public static final Argument<MessageHeaders> TYPE

Constructor Detail

KafkaHeadersBinder

public KafkaHeadersBinder()

Method Detail

argumentType

public Argument<MessageHeaders> argumentType()

Specified by:

argumentType in interface TypeArgumentBinder<MessageHeaders,ConsumerRecord<?,?>>

Returns:

The argument type.

bind

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

Description copied from interface: ArgumentBinder

Bind the given argument from the given source.

Specified by:

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

Parameters:

context - The ArgumentConversionContext

source - The source

Returns:

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