The GitHub Actions job "Nightly Build and Test" on pekko-connectors-kafka.git/main has failed. Run started by GitHub user pjfanning (triggered by pjfanning).
Head commit for run: 80170dfff3ab0ffc237b855c5fe7cdaf0bbde6d8 / Arvind Raghavan <[email protected]> Clear lastRevoked after use to avoid wiping buffers under cooperative rebalancing (#617) * 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 <[email protected]> * Address review: standard ASF header for new file, drop final vals and test logging, apply scalafmt Co-Authored-By: Claude Fable 5 <[email protected]> --------- Co-authored-by: Claude Fable 5 <[email protected]> Report URL: https://github.com/apache/pekko-connectors-kafka/actions/runs/31350599394 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
