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