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