[fix][io] Improve Kafka Connect source offset flushing logic - #24654

Merged

lhotari merged 4 commits into

apache:masterfrom

harangozop:bugfix/24646-kafka-connect-source-flush

Sep 11, 2025

Commits on Aug 21, 2025

[fix][io] Introduce a test case to simulate hanging source connector
harangozop
committed
fc6e1f4
[fix][io] Improve Kafka Connect source offset flushing logic
harangozop
committed
1b9b11a

Commits on Aug 22, 2025

[fix][io] Introduce AtomicReference to store flushFuture to increase thread safety
harangozop
committed
fd18f57

Commits on Sep 11, 2025

[fix][io] Refactor KafkaConnectSourceTests to wrap OffsetStorageWriter into a helper method for better readability
harangozop
committed
d9517c7