kafka-connect-storage-cloud icon indicating copy to clipboard operation
kafka-connect-storage-cloud copied to clipboard

feat: prevent clearing assigned topic partitions

Open mhmcdonald opened this issue 9 months ago • 1 comments

Problem

This is a duplication of the work done in https://github.com/confluentinc/kafka-connect-storage-cloud/pull/648 fixing the issue described in https://github.com/confluentinc/kafka-connect-storage-cloud/issues/649

In order to use CooperativeStickyAssignor as the partition.assignment.strategy we need to adjust how the connector clears all the assigned topicPartitionWriters on close().

Solution

Does this solution apply anywhere else?
  • [ ] yes
  • [x] no
If yes, where?

Test Strategy

Testing done:
  • [ ] Unit tests
  • [ ] Integration tests
  • [ ] System tests
  • [ ] Manual tests

Release Plan

mhmcdonald avatar Feb 03 '25 15:02 mhmcdonald

:tada: All Contributor License Agreements have been signed. Ready to merge.
:white_check_mark: mhmcdonald
Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.