Interface KafkaStreamsCustomizer

All Known Implementing Classes:
CompositeKafkaStreamsCustomizer
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface KafkaStreamsCustomizer
Callback interface that can be used to configure KafkaStreams directly.
Since:
2.1.5
Author:
Nurettin Yilmaz, Almog Gavra
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)
    Customize the instance of KafkaStreams after StreamsBuilderFactoryBean has applied its default configurations.
    default org.apache.kafka.streams.KafkaStreams
    initKafkaStreams(@Nullable org.apache.kafka.streams.Topology topology, Properties properties, org.apache.kafka.streams.KafkaClientSupplier clientSupplier)
    Customize the instantiation of the KafkaStreams instance.

  • Method Details

    • initKafkaStreams

      default org.apache.kafka.streams.KafkaStreams initKafkaStreams(@Nullable org.apache.kafka.streams.Topology topology, Properties properties, org.apache.kafka.streams.KafkaClientSupplier clientSupplier)
      Customize the instantiation of the KafkaStreams instance. This happens before the modifications made by StreamsBuilderFactoryBean.
      Parameters:
      topology - the full topology
      properties - the configuration properties
      clientSupplier - the client supplier
      Returns:
      a new instance of KafkaStreams
      Since:
      3.3.0

    • customize

      void customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)
      Customize the instance of KafkaStreams after StreamsBuilderFactoryBean has applied its default configurations.
      Parameters:
      kafkaStreams - the instantiated Kafka Streams instance