io.smallrye.reactive.messaging.kafka.converters

Class ConsumerRecordConverter

java.lang.Object

io.smallrye.reactive.messaging.kafka.converters.ConsumerRecordConverter

All Implemented Interfaces:

MessageConverter, javax.enterprise.inject.spi.Prioritized

@ApplicationScoped
public class ConsumerRecordConverter
extends Object
implements MessageConverter

Convert an incoming Kafka message into a ConsumerRecord.

Nested Class Summary

Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.MessageConverter

MessageConverter.IdentityConverter

Field Summary

Fields inherited from interface io.smallrye.reactive.messaging.MessageConverter

CONVERTER_DEFAULT_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ConsumerRecordConverter()

Method Summary

Modifier and Type	Method and Description
boolean	canConvert(Message<?> in, Type target) Checks whether this instance of converter can convert the given message in into a Message<T> with T being the type represented by target.
Message<?>	convert(Message<?> in, Type target) Converts the given message in into a Message<T>.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.smallrye.reactive.messaging.MessageConverter

getPriority

Constructor Detail

ConsumerRecordConverter

public ConsumerRecordConverter()

Method Detail

canConvert

public boolean canConvert(Message<?> in,
                          Type target)

Description copied from interface: MessageConverter

Checks whether this instance of converter can convert the given message in into a Message<T> with T being the type represented by target. When reactive messaging looks for a converter, it picks the first converter returning true for a given message.

Specified by:

canConvert in interface MessageConverter

Parameters:

in - the input message, not null

target - the target type, generally the type ingested by a method

Returns:

true if the conversion is possible, false otherwise.

convert

public Message<?> convert(Message<?> in,
                          Type target)

Description copied from interface: MessageConverter

Converts the given message in into a Message<T>. This method is only called after a successful call to MessageConverter.canConvert(Message, Type) with the given target type.

Specified by:

convert in interface MessageConverter

Parameters:

in - the input message

target - the target type

Returns:

the converted message.