public final class KafkaConditions
extends java.lang.Object
Condition
s.Modifier and Type | Class and Description |
---|---|
static class |
KafkaConditions.ConsumerRecordKeyCondition<K> |
static class |
KafkaConditions.ConsumerRecordPartitionCondition |
static class |
KafkaConditions.ConsumerRecordValueCondition<V> |
Modifier and Type | Method and Description |
---|---|
static <K> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,?>> |
key(K key) |
static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> |
partition(int partition) |
static <V> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,V>> |
value(V value) |
public static <K> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,?>> key(K key)
K
- the type.key
- the keypublic static <V> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,V>> value(V value)
V
- the type.value
- the value.public static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> partition(int partition)
partition
- the partition.