K - The key deserializer typeV - The value deserializer typepublic abstract class AbstractKafkaConsumerConfiguration<K,V> extends AbstractKafkaConfiguration<K,V>
DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX| Modifier | Constructor and Description | 
|---|---|
protected  | 
AbstractKafkaConsumerConfiguration(Properties config)
Constructs a new instance. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Optional<Deserializer<K>> | 
getKeyDeserializer()  | 
Optional<Deserializer<V>> | 
getValueDeserializer()  | 
void | 
setKeyDeserializer(Deserializer<K> keyDeserializer)
Sets the key deserializer. 
 | 
void | 
setValueDeserializer(Deserializer<V> valueDeserializer)
Sets the default value deserializer. 
 | 
getConfigprotected AbstractKafkaConsumerConfiguration(Properties config)
config - The config to usepublic Optional<Deserializer<K>> getKeyDeserializer()
Deserializerpublic void setKeyDeserializer(@Nullable Deserializer<K> keyDeserializer)
keyDeserializer - The key serializerpublic Optional<Deserializer<V>> getValueDeserializer()
Deserializerpublic void setValueDeserializer(@Nullable Deserializer<V> valueDeserializer)
valueDeserializer - The value deserializer