org.springframework.kafka.test.hamcrest

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

Constructors

Constructor and Description
ConsumerRecordTimestampMatcher(org.apache.kafka.common.record.TimestampType type, long ts)

Method Summary

Modifier and Type	Method and Description
void	describeTo(org.hamcrest.Description description)
protected boolean	matches(java.lang.Object item, org.hamcrest.Description mismatchDescription)

Methods inherited from class org.hamcrest.DiagnosingMatcher

describeMismatch, matches

Methods inherited from class org.hamcrest.BaseMatcher

_dont_implement_Matcher___instead_extend_BaseMatcher_, isNotNull, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ConsumerRecordTimestampMatcher

public ConsumerRecordTimestampMatcher(org.apache.kafka.common.record.TimestampType type,
                                      long ts)

Method Detail

matches

protected boolean matches(java.lang.Object item,
                          org.hamcrest.Description mismatchDescription)

Specified by:

matches in class org.hamcrest.DiagnosingMatcher<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>

describeTo

public void describeTo(org.hamcrest.Description description)