[kafka] Integrate Produce with native Fluss append - #4286

Draft

gyang94 wants to merge 12 commits into

apache:mainfrom

gyang94:codex/kafka-produce-append

Commits on Sep 9, 2026

[kafka] Add request dispatch and transport framework

gyang94
and
codex
committed
49b95ce
[kafka] Serve ApiVersions from registered capabilities

gyang94
and
codex
committed
0ea02c7
[kafka] Implement Metadata API over Fluss table metadata

gyang94
and
codex
committed
2212f5a

Commits on Sep 10, 2026

[kafka] Define DDL table mapping for Kafka compatibility

gyang94
and
codex
committed
6b9626d
[kafka] Use the DDL table contract in Metadata

gyang94
and
codex
committed
050b260
complete delay fetch
gyang94
committed
5352f2e
[server] Isolate delayed fetch completions and add regression tests

gyang94
and
codex
committed
e15d5d8
[test] Adapt delayed fetch tests to the current result factory

gyang94
and
codex
committed
969f985
[kafka] Add independently testable Produce protocol handling

gyang94
and
codex
committed
936fd3f
[kafka] Transcode mapped raw and string records to Arrow

gyang94
and
codex
committed
5031362
[kafka] Combine Produce and delayed-fetch prerequisites

gyang94
and
codex
committed
0e99697
[kafka] Connect Produce to native Fluss append

gyang94
and
codex
committed
dc5fb65