fix(kafka source): fix acknowledgement handling during shutdown and rebalance events#17497

Merged

jszwedko merged 40 commits intovectordotdev:masterfrom jches:kafka-shutdown-rebalance-pending-acks

Oct 12, 2023

+1,023-163

Commits on May 26, 2023

cargo fmt again
jches
committed
fmt
jches
committed

Commits on Jun 29, 2023

Commits on Jul 3, 2023

clippy warning
jches
committed

Commits on Aug 28, 2023

enhancement(kafka source): kafka source uses a dedicated task per partition to consume & acknowledge messages
jches
committed
Merge branch 'master' into kafka-shutdown-rebalance-pending-acks
jches
committed
make the spelling checker happy, maybe?
jches
committed

Commits on Aug 29, 2023

Commits on Sep 6, 2023

add OptionFuture to drain deadline and EOF handling, and use is_subset to detect when all expected partitions are finished draining
jches
committed

Commits on Sep 11, 2023

rely solely on adding/removing entries in expect_drain to detect when draining is complete
jches
committed

Commits on Sep 12, 2023

Commits on Sep 13, 2023

minor cleanup: during shutdown, use is_drain_complete to detect the already-finished state
jches
committed

Commits on Sep 20, 2023

Commits on Sep 21, 2023

integration test using 125k messages
jches
committed

Commits on Sep 22, 2023

Commits on Oct 3, 2023

use Option::{unzip, map_or} methods

jches
and
bruceg
authored

Commits on Oct 4, 2023