Fix split join - #960

Draft

DmitryRomanov wants to merge 18 commits into

Commits on Mar 18, 2026

set timeout on kafka produce
DmitryRomanov
committed
6778a93
set timeout on kafka consume
DmitryRomanov
committed
e85982b
use kafka kraft in e2e test kafka_file
DmitryRomanov
committed
32d2cc0
set kafka timeout in e2e tests
DmitryRomanov
committed
5718e1b
use kafka kraft in e2e test kafka_auth
DmitryRomanov
committed
d247eeb
add kafka for split_join e2e test
DmitryRomanov
committed
3a58814
Revert "add kafka for split_join e2e test"
DmitryRomanov
committed
3be6209
set context in kafka record
DmitryRomanov
committed
1c0f9d8
franz-go v1.20.7
DmitryRomanov
committed
7ae84cc
set context nil for record
DmitryRomanov
committed
298d7d9
wait for kafka start
DmitryRomanov
committed
c32f060
kafka consumer: use own ctx for consume
DmitryRomanov
committed
a6df143
use parent context on kafka consume
DmitryRomanov
committed
e7f7cea

Commits on Mar 19, 2026

set kafka timeouts in e2e tests
DmitryRomanov
committed
f9c9754
e2e split_join: create consumer group
DmitryRomanov
committed
137bc7a

Commits on Mar 23, 2026

kafka consumer: use only cancel context
DmitryRomanov
committed
2aadc4e
no need ForceMetadataRefresh
DmitryRomanov
committed
bcc3735
try to debyg split_join
DmitryRomanov
committed
f1882eb