io.micronaut.configuration.kafka.convert

Class KafkaHeaderConverter

java.lang.Object

io.micronaut.configuration.kafka.convert.KafkaHeaderConverter

All Implemented Interfaces:

io.micronaut.core.convert.TypeConverter<org.apache.kafka.common.header.Header,java.lang.Object>

@Singleton
public class KafkaHeaderConverter
extends java.lang.Object
implements io.micronaut.core.convert.TypeConverter<org.apache.kafka.common.header.Header,java.lang.Object>

Converts header values.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
KafkaHeaderConverter()

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.lang.Object>	convert(org.apache.kafka.common.header.Header object, java.lang.Class<java.lang.Object> targetType, io.micronaut.core.convert.ConversionContext context)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.core.convert.TypeConverter

convert, of

Constructor Detail

KafkaHeaderConverter

public KafkaHeaderConverter()

Method Detail

convert

public java.util.Optional<java.lang.Object> convert(org.apache.kafka.common.header.Header object,
                                                    java.lang.Class<java.lang.Object> targetType,
                                                    io.micronaut.core.convert.ConversionContext context)

Specified by:

convert in interface io.micronaut.core.convert.TypeConverter<org.apache.kafka.common.header.Header,java.lang.Object>