public final class KafkaMatchers
extends java.lang.Object
Matcher
s utilities.Modifier and Type | Class and Description |
---|---|
static class |
KafkaMatchers.ConsumerRecordKeyMatcher<K> |
static class |
KafkaMatchers.ConsumerRecordPartitionMatcher |
static class |
KafkaMatchers.ConsumerRecordValueMatcher<V> |
Modifier and Type | Method and Description |
---|---|
static <K> org.hamcrest.Matcher<org.apache.kafka.clients.consumer.ConsumerRecord<K,?>> |
hasKey(K key) |
static org.hamcrest.Matcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> |
hasPartition(int partition) |
static <V> org.hamcrest.Matcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,V>> |
hasValue(V value) |
public static <K> org.hamcrest.Matcher<org.apache.kafka.clients.consumer.ConsumerRecord<K,?>> hasKey(K key)
K
- the type.key
- the keypublic static <V> org.hamcrest.Matcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,V>> hasValue(V value)
V
- the type.value
- the value.public static org.hamcrest.Matcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> hasPartition(int partition)
partition
- the partition.