You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Andrea Cosentino (Jira)" <ji...@apache.org> on 2025/03/05 11:47:00 UTC
[jira] [Created] (CAMEL-21833) Kafka Batch Manual commit doesn't work if used in Kamelets
Andrea Cosentino created CAMEL-21833:
----------------------------------------
Summary: Kafka Batch Manual commit doesn't work if used in Kamelets
Key: CAMEL-21833
URL: https://issues.apache.org/jira/browse/CAMEL-21833
Project: Camel
Issue Type: Bug
Components: camel-kafka
Reporter: Andrea Cosentino
if you try this example: https://github.com/apache/camel-kamelets-examples/tree/main/jbang/kafka-batch-s3
you'll notice the manual commit never happens. If you try to log the content of the header in the batch-manual-commit-action using
https://github.com/apache/camel/blob/main/components/camel-kamelet/src/main/java/o[…]/component/kamelet/utils/transform/kafka/BatchManualCommit.java
it seems on line 34
the processor is not able to access the KafkaManualCommit instance
If you run the integration test in the kafka component, everything seems to work, but with Kamelets it's not
--
This message was sent by Atlassian Jira
(v8.20.10#820010)