K
- The key deserializer typeV
- The value deserializer typepublic abstract class AbstractKafkaProducerConfiguration<K,V> extends AbstractKafkaConfiguration<K,V>
DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX
Modifier | Constructor and Description |
---|---|
protected |
AbstractKafkaProducerConfiguration(Properties config)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
Optional<Serializer<K>> |
getKeySerializer() |
Optional<Serializer<V>> |
getValueSerializer() |
void |
setKeySerializer(Serializer<K> keySerializer)
Sets the key serializer.
|
void |
setValueSerializer(Serializer<V> valueSerializer)
Sets the default value serializer.
|
getConfig
protected AbstractKafkaProducerConfiguration(Properties config)
config
- The config to usepublic Optional<Serializer<K>> getKeySerializer()
Serializer
public void setKeySerializer(@Nullable Serializer<K> keySerializer)
keySerializer
- The key serializerpublic Optional<Serializer<V>> getValueSerializer()
Serializer
public void setValueSerializer(@Nullable Serializer<V> valueSerializer)
valueSerializer
- The value serializer