From d8a678c77edec0d041f88bf41305a3e3c666c85c Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Wed, 11 Nov 2020 13:40:19 -0500
Subject: [PATCH] Fix KafkaBinderTests - testRecordMetadata

---
 .../cloud/stream/binder/kafka/KafkaBinderTests.java           | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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) {