パッケージ org.springframework.kafka.test.rule

クラス EmbeddedKafkaRule

java.lang.ObjectSE
org.junit.rules.ExternalResource
org.springframework.kafka.test.rule.EmbeddedKafkaRule
実装されたすべてのインターフェース:
org.junit.rules.TestRule
public class EmbeddedKafkaRule extends org.junit.rules.ExternalResource
EmbeddedKafkaBroker の周囲の TestRule ラッパー。
導入:
2.2
作成者:
Artem Bilan
関連事項:

  • コンストラクターの詳細

    • EmbeddedKafkaRule

      public EmbeddedKafkaRule(int count)

    • EmbeddedKafkaRule

      public EmbeddedKafkaRule(int count, boolean controlledShutdown, StringSE... topics)
      組み込みの Kafka ブローカーを作成します。
      パラメーター:
      count - ブローカーの数。
      controlledShutdown - TestUtils.createBrokerConfig に渡されます。
      topics - 作成するトピック (1 つにつき 2 つのパーティション)。

    • EmbeddedKafkaRule

      public EmbeddedKafkaRule(int count, boolean controlledShutdown, int partitions, StringSE... topics)
      ランダムポートでリッスンする組み込み Kafka ブローカーを作成します。
      パラメーター:
      count - ブローカーの数。
      controlledShutdown - TestUtils.createBrokerConfig に渡されます。
      partitions - トピックごとのパーティション。
      topics - 作成するトピック。

  • メソッドの詳細

    • brokerProperties

      public EmbeddedKafkaRule brokerProperties(MapSE<StringSE,StringSE> brokerProperties)
      開始する前に、Kafka ブローカーを構成するためのプロパティを指定します。auto.create.topics.enable、transaction.state.log.replication.factor など。
      パラメーター:
      brokerProperties - Kafka ブローカーの構成に使用するプロパティ。
      戻り値:
      これはチェーン構成用です
      関連事項:
      • KafkaConfig

    • brokerProperty

      public EmbeddedKafkaRule brokerProperty(StringSE property, ObjectSE value)
      ブローカープロパティを指定します。
      パラメーター:
      property - プロパティ名。
      value - 値。
      戻り値:
      EmbeddedKafkaRule
      導入:
      2.1.4

    • kafkaPorts

      public EmbeddedKafkaRule kafkaPorts(int... kafkaPorts)
      kafka ブローカーがリッスンする明示的なポートを設定します。他のプロセスからアクセスしたい組み込みブローカーを実行するときに便利です。
      パラメーター:
      kafkaPorts - ポート。
      戻り値:
      ルール。

    • zkPort

      public EmbeddedKafkaRule zkPort(int port)

    • getEmbeddedKafka

      public EmbeddedKafkaBroker getEmbeddedKafka()
      基になる委譲者 EmbeddedKafkaBroker インスタンスを返します。
      戻り値:
      EmbeddedKafkaBroker インスタンス。

    • before

      public void before()
      オーバーライド:
      クラス org.junit.rules.ExternalResource の before 

    • after

      public void after()
      オーバーライド:
      クラス org.junit.rules.ExternalResource の after