クラス KafkaConditions

java.lang.ObjectSE
org.springframework.kafka.test.assertj.KafkaConditions
public final class KafkaConditions extends ObjectSE
AssertJ カスタム Conditions.
作成者:
Artem Bilan, Gary Russell, Biju Kunjummen

  • メソッドの詳細

    • 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 - パーティション。
      戻り値:
      コンシューマーレコードのパーティションに一致する条件。