Lianet Magrans ea485a7061 KAFKA-16665: Allow to initialize newly assigned partition's positions without allowing fetching while callback runs (#15856) ... Fix to allow to initialize positions for newly assigned partitions, while the onPartitionsAssigned callback is running, even though the partitions remain non-fetchable until the callback completes. Before this PR, we were not allowing initialization or fetching while the callback was running. The fix here only allows to initialize the newly assigned partition position, and keeps the existing logic for making sure that the partition remains non-fetchable until the callback completes. The need for this fix came out in one of the connect system tests, that attempts to retrieve a newly assigned partition position with a call to consumer.position from within the onPartitionsAssigned callback (WorkerSinkTask). With this PR, we allow to make such calls (test added), which is the behaviour of the legacy consumer. Reviewers: Lucas Brutschy <lbrutschy@confluent.io>		2024-05-07 10:40:00 +02:00
..
src	KAFKA-16665: Allow to initialize newly assigned partition's positions without allowing fetching while callback runs (#15856)	2024-05-07 10:40:00 +02:00
.gitignore	…