feat(kafka-logger): add configurable api_version for Apache Kafka 4.x support#13040

Closed

macdoor wants to merge 22 commits intoapache:masterfrom

macdoor:feat/kafka-logger-api-version

Commits on Feb 27, 2026

feat(kafka-logger): add configurable api_version for Apache Kafka 4.x support
段晓雄
committed
refactor(kafka-logger): address PR review feedback
段晓雄
committed
fix(kafka-logger): only pass api_version when explicitly set
段晓雄
committed
fix(kafka-logger): shorten api_version description to comply with max line length (100)
段晓雄
committed

Commits on Feb 28, 2026

Commits on Mar 2, 2026

fix(ci): add missing KRaft env vars and move Kafka 4.x init to end
段晓雄
committed

Commits on Mar 4, 2026

chore(kafka-logger,ci): use apache kafka image and align api_version default
段晓雄
committed
chore(ci): cap kafka 4.x topic creation time with timeout
段晓雄
committed
chore(ci): make kafka 4.x topic creation more robust
段晓雄
committed

Commits on Mar 6, 2026

fix(ci): use internal Kafka 4.x listener and pass bootstrap-server for --list (Copilot review)
段晓雄
committed

Commits on Mar 7, 2026

fix(ci): simplify Kafka 4.x KRaft config to fix broker startup failure
段晓雄
committed

Commits on Mar 9, 2026

fix(ci): use dual Kafka listeners to fix topic creation inside container
段晓雄
committed
ci: add kafka-logger focused workflow for fork testing
段晓雄
committed
ci(kafka-logger): wait for Kafka before init after, disable Go cache
段晓雄
committed
ci: run Build and Push apisix:dev only on master/release (fork)
段晓雄
committed
ci(kafka-logger): split plugin init steps, add before retry and openfunction build
段晓雄
committed
test(kafka-logger): relax TEST 28 timing for Kafka 4.x produce
段晓雄
committed
test(kafka-logger): skip TEST 27/28 in CI (Kafka 4.x produce flaky)
段晓雄
committed
test(kafka-logger): add local Kafka 4.x runner and fix tests
段晓雄
committed