T - The target generic type@Singleton public class KafkaBodyBinder<T> extends Object implements AnnotatedConsumerRecordBinder<Body,T>
ArgumentBinder.BindingResult<T>| Constructor and Description |
|---|
KafkaBodyBinder() |
| Modifier and Type | Method and Description |
|---|---|
Class<Body> |
annotationType() |
ArgumentBinder.BindingResult<T> |
bind(ArgumentConversionContext<T> context,
ConsumerRecord<?,?> source)
Bind the given argument from the given source.
|
public Class<Body> annotationType()
annotationType in interface AnnotatedConsumerRecordBinder<Body,T>public ArgumentBinder.BindingResult<T> bind(ArgumentConversionContext<T> context, ConsumerRecord<?,?> source)
ArgumentBinderbind in interface ArgumentBinder<T,ConsumerRecord<?,?>>context - The ArgumentConversionContextsource - The sourceOptional of the value. If no binding was possible Optional.empty()