Package com.bakdata.kafka.consumerproducer

Class SerializerDeserializerConfig

java.lang.Object

com.bakdata.kafka.consumerproducer.SerializerDeserializerConfig

All Implemented Interfaces:

SerializationConfig

public class SerializerDeserializerConfig
extends Object
implements SerializationConfig

Defines how to (de)serialize the data in a Kafka consumer or producer

Constructor Summary

Constructors

Constructor	Description
SerializerDeserializerConfig(@NonNull SerializerConfig serializerConfig, @NonNull DeserializerConfig deserializerConfig)
SerializerDeserializerConfig(@NonNull Class<? extends org.apache.kafka.common.serialization.Serializer> keySerializer, @NonNull Class<? extends org.apache.kafka.common.serialization.Serializer> valueSerializer, @NonNull Class<? extends org.apache.kafka.common.serialization.Deserializer> keyDeserializer, @NonNull Class<? extends org.apache.kafka.common.serialization.Deserializer> valueDeserializer)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	createProperties()	Create properties from this SerializationConfig
SerializerDeserializerConfig	withDeserializerConfig(@NonNull DeserializerConfig deserializerConfig)
SerializerDeserializerConfig	withSerializerConfig(@NonNull SerializerConfig serializerConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SerializerDeserializerConfig

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

SerializerDeserializerConfig

public SerializerDeserializerConfig(@NonNull
 @NonNull SerializerConfig serializerConfig,
 @NonNull
 @NonNull DeserializerConfig deserializerConfig)

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

withSerializerConfig

public SerializerDeserializerConfig withSerializerConfig(@NonNull
 @NonNull SerializerConfig serializerConfig)

Returns:

a clone of this object, except with this updated property (returns this if an identical value is passed).

withDeserializerConfig

public SerializerDeserializerConfig withDeserializerConfig(@NonNull
 @NonNull DeserializerConfig deserializerConfig)

Returns:

a clone of this object, except with this updated property (returns this if an identical value is passed).