From 2c1a6225975934534ff75f7eaecfd1e195aaf2b7 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 9 Dec 2020 13:51:27 -0500 Subject: [PATCH] Fix Elasticsearch sink test --- .../stream/app/sink/elasticsearch/ElasticsearchSinkTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); }); }