クラス KafkaConditions
java.lang.ObjectSE
org.springframework.kafka.test.assertj.KafkaConditions
AssertJ カスタム
Condition
s.- 作成者:
- Artem Bilan, Gary Russell, Biju Kunjummen
ネストされたクラスのサマリー
ネストされたクラス修飾子と型クラス説明static class
static class
static class
static class
static class
メソッドのサマリー
修飾子と型メソッド説明static <K> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,
?>> key
(K key) static <K,
V> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> keyValue
(K key, V value) static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,
?>> partition
(int partition) static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,
?>> timestamp
(long value) static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,
?>> timestamp
(org.apache.kafka.common.record.TimestampType type, long value) static <V> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,
V>> value
(V value)
メソッドの詳細
key
public static <K> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,?>> key(K key) - 型パラメーター:
K
- 型。- パラメーター:
key
- キー。- 戻り値:
- コンシューマーレコードのキーと一致する条件。
value
public static <V> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,V>> value(V value) - 型パラメーター:
V
- 型。- パラメーター:
value
- 値。- 戻り値:
- コンシューマーレコードの値と一致する条件。
keyValue
public static <K,V> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> keyValue(K key, V value) - 型パラメーター:
K
- 鍵の型。V
- 値の型。- パラメーター:
key
- キー。value
- 値。- 戻り値:
- コンシューマーレコードのキーと一致する条件。
- 導入:
- 2.2.12
timestamp
public static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> timestamp(long value) - パラメーター:
value
- タイムスタンプ。- 戻り値:
- コンシューマーレコードのタイムスタンプ値と一致する条件。
- 導入:
- 1.3
timestamp
public static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> timestamp(org.apache.kafka.common.record.TimestampType type, long value) - パラメーター:
type
- タイムスタンプの型value
- タイムスタンプ。- 戻り値:
- コンシューマーレコードのタイムスタンプ値と一致する条件。
- 導入:
- 1.3
partition
public static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> partition(int partition) - パラメーター:
partition
- パーティション。- 戻り値:
- コンシューマーレコードのパーティションに一致する条件。