クラス EmbeddedKafkaZKBroker

java.lang.ObjectSE
org.springframework.kafka.test.EmbeddedKafkaZKBroker
実装されているすべてのインターフェース:
DisposableBean、InitializingBean、EmbeddedKafkaBroker
public class EmbeddedKafkaZKBroker extends ObjectSE implements EmbeddedKafkaBroker
組み込みの Kafka ブローカーおよび Zookeeper マネージャー。このクラスは単体テストで使用することを目的としています。
導入:
2.2
作成者:
Marius Bogoevici, Artem Bilan, Gary Russell, Kamill Sokol, Elliot Kennedy, Nakul Mishra, Pawel Lozinski, Adrian Chlebosz, Soby Chacko, Sanghyeok An, Borahm Lee, Wouter Coekaerts

  • フィールドの詳細

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

    • EmbeddedKafkaZKBroker

      public EmbeddedKafkaZKBroker(int count)

    • EmbeddedKafkaZKBroker

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

    • EmbeddedKafkaZKBroker

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

  • メソッドの詳細

    • brokerProperties

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

    • brokerProperty

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

    • kafkaPorts

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

    • brokerListProperty

      public EmbeddedKafkaBroker brokerListProperty(StringSE brokerListProperty)
      この名前のシステムプロパティをブローカーアドレスのリストに設定します。3.0.10 以降、Spring Boot 互換性のためのデフォルトは spring.kafka.bootstrap-servers です。
      次で指定:
      インターフェース EmbeddedKafkaBroker の brokerListProperty 
      パラメーター:
      brokerListProperty - 設定する brokerListProperty
      戻り値:
      このブローカー。
      導入:
      2.3

    • zkPort

      public EmbeddedKafkaZKBroker zkPort(int port)
      組み込み Zookeeper の明示的なポートを設定します。
      パラメーター:
      port - ポート。
      戻り値:
      EmbeddedKafkaBroker
      導入:
      2.3

    • getZkPort

      public int getZkPort()
      組み込み Zookeeper が実行されている、または実行されるポートを取得します。
      戻り値:
      ポート。
      導入:
      2.3

    • setZkPort

      public void setZkPort(int zkPort)
      組み込み Zookeeper を実行するポートを設定します (デフォルトはランダム)。
      パラメーター:
      zkPort - ポート。
      導入:
      2.3

    • adminTimeout

      public EmbeddedKafkaBroker adminTimeout(int adminTimeout)
      インターフェースからコピーされた説明: EmbeddedKafkaBroker
      管理操作（トピックの作成、閉じるなど）のタイムアウトを秒単位で設定します。
      次で指定:
      インターフェース EmbeddedKafkaBroker の adminTimeout 
      パラメーター:
      adminTimeout - タイムアウト。
      戻り値:
      EmbeddedKafkaBroker

    • setAdminTimeout

      public void setAdminTimeout(int adminTimeout)
      管理操作（トピックの作成、閉じるなど）のタイムアウトを秒単位で設定します。デフォルトは 10 秒です。
      パラメーター:
      adminTimeout - タイムアウト。
      導入:
      2.2

    • zkConnectionTimeout

      public EmbeddedKafkaZKBroker zkConnectionTimeout(int zkConnectionTimeout)
      クライアントの接続タイムアウトを組み込み Zookeeper に設定します。
      パラメーター:
      zkConnectionTimeout - 接続タイムアウト
      戻り値:
      EmbeddedKafkaBroker
      導入:
      2.4

    • zkSessionTimeout

      public EmbeddedKafkaZKBroker zkSessionTimeout(int zkSessionTimeout)
      クライアントのセッションタイムアウトを組み込み Zookeeper に設定します。
      パラメーター:
      zkSessionTimeout - セッションタイムアウト。
      戻り値:
      EmbeddedKafkaBroker
      導入:
      2.4

    • afterPropertiesSet

      public void afterPropertiesSet()
      次で指定:
      インターフェース EmbeddedKafkaBroker の afterPropertiesSet 
      次で指定:
      インターフェース InitializingBean の afterPropertiesSet 

    • addTopics

      public void addTopics(StringSE... topicsToAdd)
      構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。ブローカーが実行されている必要があります。
      次で指定:
      インターフェース EmbeddedKafkaBroker の addTopics 
      パラメーター:
      topicsToAdd - トピック。

    • addTopics

      public void addTopics(org.apache.kafka.clients.admin.NewTopic... topicsToAdd)
      既存のブローカーにトピックを追加します。ブローカーが実行されている必要があります。
      次で指定:
      インターフェース EmbeddedKafkaBroker の addTopics 
      パラメーター:
      topicsToAdd - トピック。
      導入:
      2.2

    • addTopicsWithResults

      public MapSE<StringSE, ExceptionSE> addTopicsWithResults(StringSE... topicsToAdd)
      構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。ブローカーが実行されている必要があります。
      次で指定:
      インターフェース EmbeddedKafkaBroker の addTopicsWithResults 
      パラメーター:
      topicsToAdd - トピック。
      戻り値:
      結果 ; null 値は成功を示します。
      導入:
      2.5.4

    • addTopicsWithResults

      public MapSE<StringSE, ExceptionSE> addTopicsWithResults(org.apache.kafka.clients.admin.NewTopic... topicsToAdd)
      既存のブローカーにトピックを追加し、結果のマップを返します。ブローカーが実行されている必要があります。
      次で指定:
      インターフェース EmbeddedKafkaBroker の addTopicsWithResults 
      パラメーター:
      topicsToAdd - トピック。
      戻り値:
      結果 ; null 値は成功を示します。
      導入:
      2.5.4

    • doWithAdmin

      public void doWithAdmin(ConsumerSE<org.apache.kafka.clients.admin.AdminClient> callback)
      AdminClient を作成します。コールバックを呼び出し、管理者を確実に閉じます。
      パラメーター:
      callback - コールバック。

    • doWithAdminFunction

      public <T> T doWithAdminFunction(FunctionSE<org.apache.kafka.clients.admin.AdminClient, T> callback)
      AdminClient を作成します。コールバックを呼び出し、管理者を確実に閉じます。
      型パラメーター:
      T - 関数の戻り型。
      パラメーター:
      callback - コールバック。
      戻り値:
      結果のマップ。
      導入:
      2.5.4

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean の destroy 
      次で指定:
      インターフェース EmbeddedKafkaBroker の destroy 

    • getTopics

      public SetSE<StringSE> getTopics()
      インターフェースからコピーされた説明: EmbeddedKafkaBroker
      トピックを取得します。
      次で指定:
      インターフェース EmbeddedKafkaBroker の getTopics 
      戻り値:
      トピック。

    • getKafkaServers

      public ListSE<kafka.server.KafkaServer> getKafkaServers()

    • getKafkaServer

      public kafka.server.KafkaServer getKafkaServer(int id)

    • getZookeeper

      public EmbeddedKafkaZKBroker.EmbeddedZookeeper getZookeeper()

    • getZooKeeperClient

      public kafka.zookeeper.ZooKeeperClient getZooKeeperClient()
      ZooKeeperClient を返します。
      戻り値:
      クライアント。
      導入:
      2.3.2

    • getZookeeperConnectionString

      public StringSE getZookeeperConnectionString()

    • getBrokerAddress

      public BrokerAddress getBrokerAddress(int i)

    • getBrokerAddresses

      public BrokerAddress[] getBrokerAddresses()

    • getPartitionsPerTopic

      public int getPartitionsPerTopic()
      インターフェースからコピーされた説明: EmbeddedKafkaBroker
      トピックごとに構成されたパーティション数を取得します。
      次で指定:
      インターフェース EmbeddedKafkaBroker の getPartitionsPerTopic 
      戻り値:
      パーティション数。

    • bounce

      public void bounce(BrokerAddress brokerAddress)

    • restart

      public void restart(int index) throws ExceptionSE
      例外:
      ExceptionSE

    • getBrokersAsString

      public StringSE getBrokersAsString()
      インターフェースからコピーされた説明: EmbeddedKafkaBroker
      ブートストラップサーバーのアドレスを文字列として取得します。
      次で指定:
      インターフェース EmbeddedKafkaBroker の getBrokersAsString 
      戻り値:
      ブートストラップサーバー。

    • consumeFromAllEmbeddedTopics

      public void consumeFromAllEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      すべての埋め込みトピックにコンシューマーをサブスクライブします。
      次で指定:
      インターフェース EmbeddedKafkaBroker の consumeFromAllEmbeddedTopics 
      パラメーター:
      consumer - コンシューマー。

    • consumeFromAllEmbeddedTopics

      public void consumeFromAllEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, boolean seekToEnd)
      すべての埋め込みトピックにコンシューマーをサブスクライブします。
      次で指定:
      インターフェース EmbeddedKafkaBroker の consumeFromAllEmbeddedTopics 
      パラメーター:
      consumer - コンシューマー。
      seekToEnd - 最初ではなく最後まで追求するのは本当です。
      導入:
      2.8.2

    • consumeFromAnEmbeddedTopic

      public void consumeFromAnEmbeddedTopic(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, StringSE topic)
      埋め込みトピックの 1 つにコンシューマーをサブスクライブします。
      次で指定:
      インターフェース EmbeddedKafkaBroker の consumeFromAnEmbeddedTopic 
      パラメーター:
      consumer - コンシューマー。
      topic - トピック。

    • consumeFromAnEmbeddedTopic

      public void consumeFromAnEmbeddedTopic(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, boolean seekToEnd, StringSE topic)
      埋め込みトピックの 1 つにコンシューマーをサブスクライブします。
      次で指定:
      インターフェース EmbeddedKafkaBroker の consumeFromAnEmbeddedTopic 
      パラメーター:
      consumer - コンシューマー。
      seekToEnd - 最初ではなく最後まで追求するのは本当です。
      topic - トピック。
      導入:
      2.8.2

    • consumeFromEmbeddedTopics

      public void consumeFromEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, StringSE... topicsToConsume)
      1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。
      次で指定:
      インターフェース EmbeddedKafkaBroker の consumeFromEmbeddedTopics 
      パラメーター:
      consumer - コンシューマー。
      topicsToConsume - トピック。
      例外:
      IllegalStateExceptionSE - 埋め込まれたトピックのリストにないトピックから消費しようとした場合（2.3.4 以降）。

    • consumeFromEmbeddedTopics

      public void consumeFromEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, boolean seekToEnd, StringSE... topicsToConsume)
      1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。
      次で指定:
      インターフェース EmbeddedKafkaBroker の consumeFromEmbeddedTopics 
      パラメーター:
      consumer - コンシューマー。
      seekToEnd - 最初ではなく最後まで追求するのは本当です。
      topicsToConsume - トピック。
      例外:
      IllegalStateExceptionSE - 埋め込まれたトピックのリストにないトピックから消費しようとした場合。
      導入:
      2.8.2