Hi Team, We are using the Kafka Streaming processor to handle records, and we've encountered an issue where the record is getting committed regardless of the following configuration:
- allowManualCommit = true - autoCommitEnable = false We observed that even with these flags set, the record is still being committed automatically. Specifically, the code in question appears to be this line in the Camel Kafka component: KafkaRecordStreamingProcessorFacade.java#L122 <https://github.com/apache/camel/blob/6670c0b5d5619b04bc0175c651265cac8d429e60/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/streaming/KafkaRecordStreamingProcessorFacade.java#L122> This behavior effectively prevents the user from controlling when (or whether) a commit should occur, which is critical for our use case. We need the ability to perform a commit *only if a certain condition is met* during processing. Could you please clarify if this is the intended behavior? If not, we’d appreciate guidance on how we can enable conditional manual commit in this setup. Best regards, Adithya
