Package com.bakdata.kafka.streams

Class SerdeConfig

java.lang.Object
com.bakdata.kafka.streams.SerdeConfig
All Implemented Interfaces:
SerializationConfig
public class SerdeConfig extends Object implements SerializationConfig
Defines how to (de-)serialize the data in a Kafka Streams app

  • Constructor Details

    • SerdeConfig

      public SerdeConfig(@NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Serde> keySerde, @NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Serde> valueSerde)

  • 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

    • withKeySerde

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

    • withValueSerde

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