diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
index 4cd8c9fb6..edab415b5 100644
--- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
+++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
@@ -3558,9 +3558,9 @@ public class KafkaBinderTests extends
 			assertThat(sendResult).isNotNull();
 			RecordMetadata meta = sendResult.getHeaders().get(KafkaHeaders.RECORD_METADATA, RecordMetadata.class);
 			assertThat(meta).isNotNull()
-				.hasFieldOrPropertyWithValue("topic", testTopicName)
-				.hasFieldOrPropertyWithValue("partition", 0)
 				.hasFieldOrPropertyWithValue("offset", 0L);
+			assertThat(meta.topic()).isEqualTo(testTopicName);
+			assertThat(meta.partition()).isEqualTo(0);
 		}
 		finally {
 			if (producerBinding != null) {