What version are you using, can you please create a reproducer? I never see this before
Il gio 5 giu 2025, 09:07 Adithya Kashyap H M <adithyahm...@gmail.com> ha scritto: > 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 >
