diff --git a/applications/sink/elasticsearch-sink/src/test/java/org/springframework/cloud/stream/app/sink/elasticsearch/ElasticsearchSinkTests.java b/applications/sink/elasticsearch-sink/src/test/java/org/springframework/cloud/stream/app/sink/elasticsearch/ElasticsearchSinkTests.java
index 0817f72e..98cd185e 100644
--- a/applications/sink/elasticsearch-sink/src/test/java/org/springframework/cloud/stream/app/sink/elasticsearch/ElasticsearchSinkTests.java
+++ b/applications/sink/elasticsearch-sink/src/test/java/org/springframework/cloud/stream/app/sink/elasticsearch/ElasticsearchSinkTests.java
@@ -65,7 +65,7 @@ public class ElasticsearchSinkTests {
 					GetRequest getRequest = new GetRequest("foo").id("1");
 					final GetResponse response = restHighLevelClient.get(getRequest, RequestOptions.DEFAULT);
 					assertThat(response.isExists()).isTrue();
-					assertThat(response.getSource().containsKey(jsonObject)).isTrue();
+					assertThat(response.getSourceAsString()).isEqualTo(jsonObject);
 				});
 	}