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

Fix Elasticsearch sink test

Browse Source
This commit is contained in:
Soby Chacko
2020-12-09 13:51:27 -05:00
parent 0d6c21b405
commit 2c1a622597
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
applications/sink/elasticsearch-sink/src/test/java/org/springframework/cloud/stream/app/sink/elasticsearch/ElasticsearchSinkTests.java
View File

@@ -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);
});
}