Class KafkaJsonDeserializerConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
io.confluent.kafka.serializers.KafkaJsonDecoderConfig
io.confluent.kafka.serializers.KafkaJsonDeserializerConfig

public class KafkaJsonDeserializerConfig extends KafkaJsonDecoderConfig
Deserializer configuration for KafkaJsonDeserializer. It's slightly odd to have this extend KafkaJsonDecoderConfig (in most other cases the Decoder variants extend from the Deserializer version), but the reason is that Decoder doesn't provide the ability to distinguish between constructing serializers for keys or for values. So the type configuration options do not work with KafkaJsonDecoder.
  • Field Details

  • Constructor Details

    • KafkaJsonDeserializerConfig

      public KafkaJsonDeserializerConfig(Map<?,?> props)