davsclaus opened a new pull request, #23251: URL: https://github.com/apache/camel/pull/23251
## Backport of #23248 Cherry-pick of #23248 onto `camel-4.14.x`. **Original PR:** #23248 - Camel 23523 kafka batch interval reset **Original author:** @FNaughton **Target branch:** `camel-4.14.x` ### Original description Fixes a bug where `intervalWatch` is never reset when `exchangeList` transitions from empty to non-empty, unlike `timeoutWatch` which is reset at that point. After an idle period longer than `batchingIntervalMs`, the watch is pre-expired, causing `hasExpiredRecords()` to fire on the very next poll that returns records, flushing a prematurely small batch. Fix: add `intervalWatch.restart()` alongside `timeoutWatch.takenAndRestart()` in the `exchangeList.isEmpty()` branch of `processExchange()`. _Claude Code on behalf of Claus Ibsen_ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
