You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/01/30 10:35:57 UTC
(camel-kamelets) 06/06: Support Kafka Batch as Kamelet source - Kafka Not Secured Source as batch
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 <an...@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 <an...@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);