public final class KafkaConditions
extends java.lang.Object
Condition
s.Modifier and Type | Class and Description |
---|---|
static class |
KafkaConditions.ConsumerRecordKeyCondition<K> |
static class |
KafkaConditions.ConsumerRecordKeyValueCondition<K,V> |
static class |
KafkaConditions.ConsumerRecordPartitionCondition |
static class |
KafkaConditions.ConsumerRecordTimestampCondition |
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 <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) |
public static <K> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,?>> key(K key)
K
- the type.key
- the key.public 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 <K,V> org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> keyValue(K key, V value)
K
- the key type.V
- the value type.key
- the key.value
- the value.public static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> timestamp(long value)
value
- the 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
- the type of timestampvalue
- the timestamp.public static org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> partition(int partition)
partition
- the partition.