org.springframework.kafka.test.assertj

Class KafkaConditions.ConsumerRecordTimestampCondition

java.lang.Object

org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>

org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordTimestampCondition

All Implemented Interfaces:

org.assertj.core.api.Descriptable<org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>>

Enclosing class:

KafkaConditions

public static class KafkaConditions.ConsumerRecordTimestampCondition
extends org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	matches(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> value)

Methods inherited from class org.assertj.core.api.Condition

as, as, describedAs, describedAs, description, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecordTimestampCondition

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

Method Detail

matches

public boolean matches(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> value)

Specified by:

matches in class org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>