public static class KafkaConditions.ConsumerRecordTimestampCondition
extends org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
Constructor and Description |
---|
ConsumerRecordTimestampCondition(org.apache.kafka.common.record.TimestampType type,
long ts) |
Modifier and Type | Method and Description |
---|---|
boolean |
matches(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> value) |