[GH] (pekko-connectors-kafka/fix-cooperative-lastRevoked): Workflow run "CI" failed!

[GitBox <gi...@apache.org>]

The GitHub Actions job "CI" on pekko-connectors-kafka.git/fix-cooperative-lastRevoked has failed.
Run started by GitHub user raghavan-arvind (triggered by pjfanning).

Head commit for run:
f440cee989aa637e5e87bc3bd590891e4351d22e / Arvind Raghavan <ra...@gmail.com>
Clear lastRevoked after use to avoid wiping buffers under cooperative rebalancing

* With the cooperative rebalance protocol onPartitionsRevoked is only invoked on
  members that actually revoke partitions, while onPartitionsAssigned is invoked
  on every member in every rebalance. A stale lastRevoked set from an earlier
  rebalance was re-applied on such assignment callbacks and filtered buffered
  records of partitions that remained assigned, losing records without them
  being processed or committed.
* Reset lastRevoked after the flush in SingleSourceLogic and SubSourceLogic.
* Run the RebalanceSpec buffer tests against both the eager and cooperative
  protocols using a cooperative variant of the test assignor.
* Add CooperativeRebalanceSpec reproducing the record loss for plain and
  partitioned sources; both tests fail without the fix.

Fixes #616

Co-Authored-By: Claude Fable 5 <no...@anthropic.com>

Report URL: https://github.com/apache/pekko-connectors-kafka/actions/runs/31044550795

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org