Class KafkaConditions.ConsumerRecordPartitionCondition
java.lang.Object
org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition
- 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.ConsumerRecordPartitionCondition
extends org.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
-
Nested Class Summary
Nested classes/interfaces inherited from class org.assertj.core.api.Condition
org.assertj.core.api.Condition.Status -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanmatches(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> value) Methods inherited from class org.assertj.core.api.Condition
conditionDescriptionWithStatus, describedAs, description, status, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.assertj.core.api.Descriptable
as, as, as, describedAs
-
Constructor Details
-
ConsumerRecordPartitionCondition
public ConsumerRecordPartitionCondition(int partition)
-
-
Method Details
-
matches
public boolean matches(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> value) - Overrides:
matchesin classorg.assertj.core.api.Condition<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
-