Class DefaultKafkaStreamsConfiguration<K,V>

Type Parameters:
K - The key deserializer type
V - The value deserializer type
All Implemented Interfaces:
io.micronaut.core.util.Toggleable

@Requires(missingProperty="kafka.streams.default") @Requires(beans=KafkaDefaultConfiguration.class) @Singleton @Named("default") @Primary public class DefaultKafkaStreamsConfiguration<K,V> extends AbstractKafkaStreamsConfiguration<K,V>
The default streams configuration is non other is present.
Since:
1.0
Author:
graemerocher
  • Constructor Details

    • DefaultKafkaStreamsConfiguration

      public DefaultKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration, io.micronaut.runtime.ApplicationConfiguration applicationConfiguration, io.micronaut.context.env.Environment environment)
      Construct a new KafkaStreamsConfiguration for the given defaults.
      Parameters:
      defaultConfiguration - The default configuration
      applicationConfiguration - The application configuration
      environment - The environment