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
ConstructorsConstructorDescriptionConsumerRecordTimestampMatcher(org.apache.kafka.common.record.TimestampType type, long ts) -
Method Summary
Modifier and TypeMethodDescriptionvoiddescribeTo(org.hamcrest.Description description) protected booleanMethods inherited from class org.hamcrest.DiagnosingMatcher
describeMismatch, matchesMethods 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:
matchesin classorg.hamcrest.DiagnosingMatcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
-
describeTo
public void describeTo(org.hamcrest.Description description)
-