クラス KafkaConditions

メソッドの詳細

• 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 - パーティション。

  戻り値:

  コンシューマーレコードのパーティションに一致する条件。