インターフェース EmbeddedKafkaBroker

メソッドの詳細

• kafkaPorts

  EmbeddedKafkaBroker kafkaPorts(int... ports)

  kafka ブローカーがリッスンする明示的なポートを設定します。他のプロセスからアクセスしたい組み込みブローカーを実行するときに便利です。

  パラメーター:

  ports - ポート。

  戻り値:

  EmbeddedKafkaBroker

• getTopics

  SetSE<StringSE> getTopics()

  トピックを取得します。

  戻り値:

  トピック。

• destroy

  default void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

• afterPropertiesSet

  default void afterPropertiesSet()

  次で指定:

  インターフェース InitializingBean の afterPropertiesSet 

• brokerProperties

  EmbeddedKafkaBroker brokerProperties(MapSE<StringSE,StringSE> properties)

  開始する前に、Kafka ブローカーを構成するためのプロパティを指定します。auto.create.topics.enable、transaction.state.log.replication.factor など。

  パラメーター:

  properties - Kafka ブローカーの構成に使用するプロパティ。

  戻り値:

  これはチェーン構成用です。

  関連事項:

  • KafkaConfig

• brokerListProperty

  EmbeddedKafkaBroker brokerListProperty(StringSE brokerListProperty)

  この名前のシステムプロパティをブローカーアドレスのリストに設定します。Spring Boot 互換性のため、デフォルトは spring.kafka.bootstrap-servers です。

  パラメーター:

  brokerListProperty - 設定する brokerListProperty

  戻り値:

  このブローカー。

• getBrokersAsString

  StringSE getBrokersAsString()

  ブートストラップサーバーのアドレスを文字列として取得します。

  戻り値:

  ブートストラップサーバー。

• addTopics

  void addTopics(StringSE... topicsToAdd)

  構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。ブローカーが実行されている必要があります。

  パラメーター:

  topicsToAdd - トピック。

• addTopics

  void addTopics(org.apache.kafka.clients.admin.NewTopic... topicsToAdd)

  既存のブローカーにトピックを追加します。ブローカーが実行されている必要があります。

  パラメーター:

  topicsToAdd - トピック。

• addTopicsWithResults

  MapSE<StringSE,ExceptionSE> addTopicsWithResults(org.apache.kafka.clients.admin.NewTopic... topicsToAdd)

  既存のブローカーにトピックを追加し、結果のマップを返します。ブローカーが実行されている必要があります。

  パラメーター:

  topicsToAdd - トピック。

  戻り値:

  結果 ; null 値は成功を示します。

• addTopicsWithResults

  MapSE<StringSE,ExceptionSE> addTopicsWithResults(StringSE... topicsToAdd)

  構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。ブローカーが実行されている必要があります。

  パラメーター:

  topicsToAdd - トピック。

  戻り値:

  結果 ; null 値は成功を示します。

• consumeFromEmbeddedTopics

  void consumeFromEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, boolean seekToEnd, StringSE... topicsToConsume)

  1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

  パラメーター:

  consumer - コンシューマー。

  topicsToConsume - トピック。

  seekToEnd - 最初ではなく最後まで追求するのは本当です。

  例外:

  IllegalStateExceptionSE - 埋め込まれたトピックのリストにないトピックから消費しようとした場合。

• consumeFromEmbeddedTopics

  void consumeFromEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, StringSE... topicsToConsume)

  1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

  パラメーター:

  consumer - コンシューマー。

  topicsToConsume - トピック。

  例外:

  IllegalStateExceptionSE - 埋め込まれたトピックのリストにないトピックから消費しようとした場合。

• consumeFromAnEmbeddedTopic

  void consumeFromAnEmbeddedTopic(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, boolean seekToEnd, StringSE topic)

  埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

  パラメーター:

  consumer - コンシューマー。

  seekToEnd - 最初ではなく最後まで追求するのは本当です。

  topic - トピック。

• consumeFromAnEmbeddedTopic

  void consumeFromAnEmbeddedTopic(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, StringSE topic)

  埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

  パラメーター:

  consumer - コンシューマー。

  topic - トピック。

• consumeFromAllEmbeddedTopics

  void consumeFromAllEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, boolean seekToEnd)

  すべての埋め込みトピックにコンシューマーをサブスクライブします。

  パラメーター:

  seekToEnd - 最初ではなく最後まで追求するのは本当です。

  consumer - コンシューマー。

• consumeFromAllEmbeddedTopics

  void consumeFromAllEmbeddedTopics(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)

  すべての埋め込みトピックにコンシューマーをサブスクライブします。

  パラメーター:

  consumer - コンシューマー。

• getPartitionsPerTopic

  int getPartitionsPerTopic()

  トピックごとに構成されたパーティション数を取得します。

  戻り値:

  パーティション数。