Package org.springframework.kafka.test.hamcrest

Class 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 Description
      ConsumerRecordTimestampMatcher​(org.apache.kafka.common.record.TimestampType type, long ts)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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)