@Singleton public class KafkaHeadersBinder extends Object implements TypedConsumerRecordBinder<MessageHeaders>
MessageHeaders
object for Kafka.ArgumentBinder.BindingResult<T>
Modifier and Type | Field and Description |
---|---|
static Argument<MessageHeaders> |
TYPE |
Constructor and Description |
---|
KafkaHeadersBinder() |
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.
|
public static final Argument<MessageHeaders> TYPE
public Argument<MessageHeaders> argumentType()
argumentType
in interface TypeArgumentBinder<MessageHeaders,ConsumerRecord<?,?>>
public ArgumentBinder.BindingResult<MessageHeaders> bind(ArgumentConversionContext<MessageHeaders> context, ConsumerRecord<?,?> source)
ArgumentBinder
bind
in interface ArgumentBinder<MessageHeaders,ConsumerRecord<?,?>>
context
- The ArgumentConversionContext
source
- The sourceOptional
of the value. If no binding was possible Optional.empty()