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.
|
getConfig
protected AbstractKafkaConsumerConfiguration(Properties config)
config
- The config to usepublic Optional<Deserializer<K>> getKeyDeserializer()
Deserializer
public void setKeyDeserializer(@Nullable Deserializer<K> keyDeserializer)
keyDeserializer
- The key serializerpublic Optional<Deserializer<V>> getValueDeserializer()
Deserializer
public void setValueDeserializer(@Nullable Deserializer<V> valueDeserializer)
valueDeserializer
- The value deserializer