This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 061e0660203eba0aed1f6f8b01d2f29f7c57672b Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Oct 14 12:38:00 2020 +0200 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - Fixed catalog test --- .../camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java index 81a67eb..2c146c4 100644 --- a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java +++ b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java @@ -58,7 +58,7 @@ class CamelKafkaConnectorCatalogTest { assertEquals("camel.sink.endpoint.amazonS3Client", model.getOptions().get(1).getName()); assertEquals("camel.sink.endpoint.autoCreateBucket", model.getOptions().get(2).getName()); assertEquals(model.getConverters().size(), 1); - assertNull(model.getTransforms()); + assertEquals(model.getTransforms().size(), 1); assertNull(model.getAggregationStrategies()); }
