インターフェースの使用
org.springframework.kafka.test.EmbeddedKafkaBroker
EmbeddedKafkaBroker を使用するパッケージ
パッケージ
説明
EmbeddedKafka のトップレベル API を提供します。
JUnit5 条件のクラスを提供します。
ユーティリティパッケージ。
org.springframework.kafka.test 内の EmbeddedKafkaBroker 使用
EmbeddedKafkaBroker を実装している org.springframework.kafka.test のクラス修飾子と型メソッド説明EmbeddedKafkaBroker.adminTimeout(int adminTimeout) 管理操作のタイムアウトを秒単位で設定します (例:EmbeddedKafkaKraftBroker.adminTimeout(int adminTimeout) EmbeddedKafkaBroker.brokerListProperty(StringSE brokerListProperty) この名前のシステムプロパティをブローカーアドレスのリストに設定します。EmbeddedKafkaKraftBroker.brokerListProperty(StringSE brokerListProperty) この名前のシステムプロパティをブローカーアドレスのリストに設定します。EmbeddedKafkaBroker.brokerProperties(MapSE<StringSE, StringSE> properties) 開始前に Kafka ブローカーを構成するためのプロパティを指定します。EmbeddedKafkaKraftBroker.brokerProperties(MapSE<StringSE, StringSE> properties) 開始前に Kafka ブローカーを構成するためのプロパティを指定します。EmbeddedKafkaKraftBroker.brokerProperty(StringSE property, ObjectSE value) ブローカープロパティを指定します。static EmbeddedKafkaBrokerEmbeddedKafkaBrokerFactory.create(EmbeddedKafka embeddedKafka) EmbeddedKafkaアノテーションに基づいてEmbeddedKafkaBrokerを作成します。static EmbeddedKafkaBrokerEmbeddedKafkaBrokerFactory.create(EmbeddedKafka embeddedKafka, FunctionSE<StringSE, StringSE> propertyResolver) EmbeddedKafkaアノテーションに基づいてEmbeddedKafkaBrokerを作成します。EmbeddedKafkaBroker.kafkaPorts(int... ports) kafka ブローカーがリッスンする明示的なポートを設定します。org.springframework.kafka.test.condition 内の EmbeddedKafkaBroker 使用
org.springframework.kafka.test.utils 内の EmbeddedKafkaBroker 使用
型 EmbeddedKafkaBroker のパラメーターを持つ org.springframework.kafka.test.utils のメソッド修飾子と型メソッド説明KafkaTestUtils.consumerProps(StringSE group, StringSE autoCommit, EmbeddedKafkaBroker embeddedKafka) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。KafkaTestUtils.consumerProps(EmbeddedKafkaBroker embeddedKafka, StringSE group, boolean autoCommit) <Integer, String>コンシューマーのテストプロパティを設定します。KafkaTestUtils.producerProps(EmbeddedKafkaBroker embeddedKafka) <Integer, String>プロデューサーのテストプロパティを設定します。
KafkaTestUtils.consumerProps(EmbeddedKafkaBroker, String, boolean)を使用してください