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. 
 | 
getConfigprotected AbstractKafkaProducerConfiguration(Properties config)
config - The config to usepublic Optional<Serializer<K>> getKeySerializer()
Serializerpublic void setKeySerializer(@Nullable Serializer<K> keySerializer)
keySerializer - The key serializerpublic Optional<Serializer<V>> getValueSerializer()
Serializerpublic void setValueSerializer(@Nullable Serializer<V> valueSerializer)
valueSerializer - The value serializer