Class KafkaStreamsConfiguration<K,V>

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

@EachProperty(value="kafka.streams", primary="default") @Requires(beans=KafkaDefaultConfiguration.class) public class KafkaStreamsConfiguration<K,V> extends AbstractKafkaStreamsConfiguration<K,V>
The default configuration passed to KafkaStreams.
  • Field Details

  • Constructor Details

    • KafkaStreamsConfiguration

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