This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch kafka-batch-source in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 86e7cdca03288f28ff589465887f98966c6c6175 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Tue Jan 30 11:35:35 2024 +0100 Support Kafka Batch as Kamelet source - Kafka Not Secured Source as batch Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 993a7fd6..3e82a7fb 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -189,12 +189,12 @@ public class KameletsCatalogTest { verifyHeaders("jira-add-issue-sink", 17); verifyHeaders("jira-source", 3); verifyHeaders("jira-oauth-source", 3); - verifyHeaders("jms-amqp-10-source", 14); - verifyHeaders("jms-amqp-10-sink", 17); - verifyHeaders("jms-apache-artemis-source", 14); - verifyHeaders("jms-apache-artemis-sink", 17); - verifyHeaders("jms-ibm-mq-source", 14); - verifyHeaders("jms-ibm-mq-sink", 17); + verifyHeaders("jms-amqp-10-source", 15); + verifyHeaders("jms-amqp-10-sink", 18); + verifyHeaders("jms-apache-artemis-source", 15); + verifyHeaders("jms-apache-artemis-sink", 18); + verifyHeaders("jms-ibm-mq-source", 15); + verifyHeaders("jms-ibm-mq-sink", 18); verifyHeaders("kafka-source", 9); verifyHeaders("kafka-sink", 5); verifyHeaders("kafka-ssl-source", 9);