SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix KafkaBinderTests - testRecordMetadata

Browse Source
This commit is contained in:
Soby Chacko
2020-11-11 13:40:19 -05:00
parent 23ce9e3d6e
commit d8a678c77e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
View File

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