Claus Ibsen created CAMEL-24198:
-----------------------------------
Summary: camel-azure-eventhubs - Redesign checkpoint store to use
per-partition batching
Key: CAMEL-24198
URL: https://issues.apache.org/jira/browse/CAMEL-24198
Project: Camel
Issue Type: Improvement
Components: camel-azure-eventhubs
Reporter: Claus Ibsen
The EventHubs consumer currently uses a single
lastTask/processedEvents/lastScheduledTask set of fields shared across all
partitions. This means checkpoint commits from different partitions can
interfere with each other, and the batch counter does not accurately reflect
per-partition progress.
The fix requires changing these single fields to per-partition maps (keyed by
partitionId), so each partition independently tracks its processed event count
and schedules its own checkpoint commit. This is an architectural change that
needs focused review.
Found during the CAMEL-24158 code review (finding #6).
Affected file: EventHubsConsumer.java
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
