インターフェース KafkaStreamsCustomizer

すべての既知の実装クラス:
CompositeKafkaStreamsCustomizer
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface KafkaStreamsCustomizer
KafkaStreams を直接構成するために使用できるコールバックインターフェース。
導入:
2.1.5
作成者:
Nurettin Yilmaz, Almog Gavra
関連事項:

  • 方法の概要

    修飾子と型
    メソッド
    説明
    void
    customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)
    StreamsBuilderFactoryBean がデフォルト構成を適用した後、KafkaStreams のインスタンスをカスタマイズします。
    default org.apache.kafka.streams.KafkaStreams
    initKafkaStreams(org.apache.kafka.streams.Topology topology, PropertiesSE properties, org.apache.kafka.streams.KafkaClientSupplier clientSupplier)
    KafkaStreams インスタンスのインスタンス化をカスタマイズします。

  • メソッドの詳細

    • initKafkaStreams

      default org.apache.kafka.streams.KafkaStreams initKafkaStreams(org.apache.kafka.streams.Topology topology, PropertiesSE properties, org.apache.kafka.streams.KafkaClientSupplier clientSupplier)
      KafkaStreams インスタンスのインスタンス化をカスタマイズします。これは、StreamsBuilderFactoryBean による変更の前に行われます。
      パラメーター:
      topology - 完全なトポロジー
      properties - 構成プロパティ
      clientSupplier - クライアントサプライヤー
      戻り値:
      KafkaStreams の新しいインスタンス
      導入:
      3.3.0

    • customize

      void customize(org.apache.kafka.streams.KafkaStreams kafkaStreams)
      StreamsBuilderFactoryBean がデフォルト構成を適用した後、KafkaStreams のインスタンスをカスタマイズします。
      パラメーター:
      kafkaStreams - インスタンス化された Kafka ストリームインスタンス