Class KafkaMatchers.ConsumerRecordTimestampMatcher
java.lang.Object
org.hamcrest.BaseMatcher<T>
org.hamcrest.DiagnosingMatcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
- All Implemented Interfaces:
org.hamcrest.Matcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,
,?>> org.hamcrest.SelfDescribing
- Enclosing class:
- KafkaMatchers
public static class KafkaMatchers.ConsumerRecordTimestampMatcher
extends org.hamcrest.DiagnosingMatcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
-
Constructor Summary
ConstructorDescriptionConsumerRecordTimestampMatcher
(org.apache.kafka.common.record.TimestampType type, long ts) -
Method Summary
Modifier and TypeMethodDescriptionvoid
describeTo
(org.hamcrest.Description description) protected boolean
Methods inherited from class org.hamcrest.DiagnosingMatcher
describeMismatch, matches
Methods inherited from class org.hamcrest.BaseMatcher
_dont_implement_Matcher___instead_extend_BaseMatcher_, isNotNull, toString
-
Constructor Details
-
ConsumerRecordTimestampMatcher
public ConsumerRecordTimestampMatcher(org.apache.kafka.common.record.TimestampType type, long ts)
-
-
Method Details
-
matches
- Specified by:
matches
in classorg.hamcrest.DiagnosingMatcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,
?>>
-
describeTo
public void describeTo(org.hamcrest.Description description)
-