クラス EmbeddedKafkaKraftBroker

メソッドの詳細

• 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 - 値。

  戻り値:

  EmbeddedKafkaKraftBroker

• kafkaPorts

  public EmbeddedKafkaKraftBroker kafkaPorts(int... ports)

  IMPORTANT: KRaft ベースの EmbeddedKafka を使用する場合、カスタムポートを構成することはできません。KafkaClusterTestKit は現時点ではカスタムポートの設定をサポートしていません。このプロパティは使用されません。Kafka ブローカーがリッスンする明示的なポートを設定します。他のプロセスからアクセスする組み込みブローカーを実行する場合に便利です。

  次で指定:

  インターフェース EmbeddedKafkaBroker の kafkaPorts 

  パラメーター:

  ports - ポート。

  戻り値:

  EmbeddedKafkaKraftBroker

• brokerListProperty

  public EmbeddedKafkaBroker brokerListProperty(StringSE brokerListProperty)

  この名前のシステムプロパティをブローカーアドレスのリストに設定します。

  次で指定:

  インターフェース EmbeddedKafkaBroker の brokerListProperty 

  パラメーター:

  brokerListProperty - 設定する brokerListProperty

  戻り値:

  このブローカー。

  導入:

  2.3

• adminTimeout

  public EmbeddedKafkaBroker adminTimeout(int adminTimeout)

  管理操作（トピックの作成、閉じるなど）のタイムアウトを秒単位で設定します。

  パラメーター:

  adminTimeout - タイムアウト。

  戻り値:

  EmbeddedKafkaKraftBroker

  導入:

  2.8.5

• setAdminTimeout

  public void setAdminTimeout(int adminTimeout)

  管理操作（トピックの作成、閉じるなど）のタイムアウトを秒単位で設定します。デフォルトは 10 秒です。

  パラメーター:

  adminTimeout - タイムアウト。

  導入:

  2.2

• afterPropertiesSet

  public void afterPropertiesSet()

  次で指定:

  インターフェース EmbeddedKafkaBroker の afterPropertiesSet 

  次で指定:

  インターフェース InitializingBean の afterPropertiesSet 

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

  次で指定:

  インターフェース EmbeddedKafkaBroker の destroy 

• 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

• getTopics

  public SetSE<StringSE> getTopics()

  インターフェースからコピーされた説明: EmbeddedKafkaBroker

  トピックを取得します。

  次で指定:

  インターフェース EmbeddedKafkaBroker の getTopics 

  戻り値:

  トピック。

• getPartitionsPerTopic

  public int getPartitionsPerTopic()

  インターフェースからコピーされた説明: EmbeddedKafkaBroker

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

  次で指定:

  インターフェース EmbeddedKafkaBroker の getPartitionsPerTopic 

  戻り値:

  パーティション数。

• getBrokersAsString

  public StringSE getBrokersAsString()

  インターフェースからコピーされた説明: EmbeddedKafkaBroker

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

  次で指定:

  インターフェース EmbeddedKafkaBroker の getBrokersAsString 

  戻り値:

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

• getCluster

  public kafka.testkit.KafkaClusterTestKit getCluster()

• 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 

  パラメーター:

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

  consumer - コンシューマー。

  導入:

  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 - コンシューマー。

  topicsToConsume - トピック。

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

  例外:

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

  導入:

  2.8.2