Add partition-level idle detection to prevent message loss on ownership transfer - #39

Draft

nodece with Copilot wants to merge 9 commits into

copilot/add-partition-idle-detection

Commits on Jan 15, 2026

Initial plan
Copilot
committed
Add PartitionConsumerIdleDetector and integrate into ConsumerImpl

Copilot
and
nodece
committed
Add comprehensive unit tests for PartitionConsumerIdleDetector

Copilot
and
nodece
committed
Address code review feedback: fix NPE, ClassCastException, and extract magic numbers

Copilot
and
nodece
committed
Fix LookupTopicResult constructor calls and improve initial delay for idle detection

Copilot
and
nodece
committed
Improve code quality: extract cleanup method, add exception handling, improve test reliability

Copilot
and
nodece
committed
Remove enablePartitionOwnershipCheck and eliminate null checks with no-op detector pattern

Copilot
and
nodece
committed
Add race condition handling between broker notification and idle detector reconnect

Copilot
and
nodece
committed
Fix potential NPE by always initializing lastActivityTimestamp

Copilot
and
nodece
committed