public static class KafkaConditions.ConsumerRecordKeyValueCondition<K,V>
extends org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
| Constructor and Description |
|---|
ConsumerRecordKeyValueCondition(K key,
V value) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
matches(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> value) |