You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/01/14 12:26:23 UTC

[camel-kafka-connector] 06/14: Simplified assertion in the elastic search sink test

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit e886eabbc322f5c1093b759611bc06576756b94d
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Jan 13 15:09:41 2021 +0100

    Simplified assertion in the elastic search sink test
---
 .../kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
index c30f735..8358aac 100644
--- a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
+++ b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
@@ -97,7 +97,7 @@ public class CamelSinkElasticSearchITCase extends AbstractKafkaTest {
     private void verifyHit(SearchHit searchHit) {
         String source = searchHit.getSourceAsString();
 
-        assertTrue(source != null);
+        assertNotNull(source);
         assertFalse(source.isEmpty());
 
         // TODO: this is not enough, we need to parse the json and check the key itself