Package com.bakdata.kafka.producer

Class SerializerConfig

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

  • Constructor Details

    • SerializerConfig

      public SerializerConfig(@NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Serializer> keySerializer, @NonNull @NonNull Class<? extends org.apache.kafka.common.serialization.Serializer> valueSerializer)

  • 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

    • withKeySerializer

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

    • withValueSerializer

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