K
- The key deserializer typeV
- The value deserializer typepublic class AbstractKafkaStreamsConfiguration<K,V> extends AbstractKafkaConfiguration<K,V>
DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX
Modifier | Constructor and Description |
---|---|
protected |
AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration)
Construct a new
KafkaStreamsConfiguration for the given defaults. |
Modifier and Type | Method and Description |
---|---|
protected void |
init(ApplicationConfiguration applicationConfiguration,
Environment environment,
Properties config)
Shared initialization.
|
getConfig
protected AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration)
KafkaStreamsConfiguration
for the given defaults.defaultConfiguration
- The default configurationprotected void init(ApplicationConfiguration applicationConfiguration, Environment environment, Properties config)
applicationConfiguration
- The application configenvironment
- The envconfig
- The config to be initialized