K - V - @Requires(missingProperty="kafka.streams.default") @Requires(beans=KafkaDefaultConfiguration.class) @Singleton @Named(value="default") @Primary public class DefaultKafkaStreamsConfiguration<K,V> extends AbstractKafkaStreamsConfiguration<K,V>
DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX| Constructor and Description |
|---|
DefaultKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration,
ApplicationConfiguration applicationConfiguration,
Environment environment)
Construct a new
KafkaStreamsConfiguration for the given defaults. |
initgetConfigpublic DefaultKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration, ApplicationConfiguration applicationConfiguration, Environment environment)
KafkaStreamsConfiguration for the given defaults.defaultConfiguration - The default configurationapplicationConfiguration - The application configurationenvironment - The environment