Class KafkaHeaderConverter

java.lang.Object
io.micronaut.configuration.kafka.convert.KafkaHeaderConverter
All Implemented Interfaces:
io.micronaut.core.convert.TypeConverter<Header,Object>

@Singleton public class KafkaHeaderConverter extends Object implements io.micronaut.core.convert.TypeConverter<Header,Object>
Converts header values.
Since:
1.0
Author:
graemerocher
  • Constructor Details

    • KafkaHeaderConverter

      public KafkaHeaderConverter(io.micronaut.core.convert.ConversionService conversionService)
      Default constructor.
      Parameters:
      conversionService - The conversion service
  • Method Details

    • convert

      public Optional<Object> convert(Header object, Class<Object> targetType, io.micronaut.core.convert.ConversionContext context)
      Specified by:
      convert in interface io.micronaut.core.convert.TypeConverter<Header,Object>