クラス EmbeddedKafkaZKBroker

メソッドの詳細

• 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 

  パラメーター:

  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