Package com.bakdata.kafka

Class DeserializerConfig

java.lang.Object
com.bakdata.kafka.DeserializerConfig
All Implemented Interfaces:
SerializationConfig
public class DeserializerConfig extends Object implements SerializationConfig
Defines how to serialize the data in a Kafka producer

  • Constructor Details

    • DeserializerConfig

      public DeserializerConfig(@NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Deserializer> keyDeserializer, @NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Deserializer> valueDeserializer)

  • Method Details

    • createProperties

      public Map<String,Object> createProperties()
      Description copied from interface: SerializationConfig
      Create properties from this SerializationConfig
      Specified by:
      createProperties in interface SerializationConfig
      Returns:
      Map of serialization configurations

    • withKeyDeserializer

      public DeserializerConfig withKeyDeserializer(@NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Deserializer> keyDeserializer)
      Returns:
      a clone of this object, except with this updated property (returns this if an identical value is passed).

    • withValueDeserializer

      public DeserializerConfig withValueDeserializer(@NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Deserializer> valueDeserializer)
      Returns:
      a clone of this object, except with this updated property (returns this if an identical value is passed).