This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-sasl-handshake-v0
in repository https://gitbox.apache.org/repos/asf/iggy.git
from cec7838f5 feat(gateways): accept SaslHandshake v0 from older Kafka
clients
add ec5d4b189 fix(connectors): tighten Iceberg sink redelivery skip and
error mapping (#4775)
add 89cb6d13f docs: let maintainers close agent-driven PRs (#4773)
add fe989f10b feat(gateways): map Kafka topic configs and replication
factor to Iggy (#4747)
add 1fb58a67d fix(node): reject malformed user headers before sending
(#4764)
add a67f5da6d Merge branch 'master' into kafka-sasl-handshake-v0
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-sink/SKILL.md | 2 +-
.config/nextest.toml | 5 +-
.github/workflows/issue-labeler-assigner.yml | 127 +-
.github/workflows/pr-triage-apply.yml | 2 +-
AGENTS.md | 6 +-
CONTRIBUTING.md | 51 +-
PULL_REQUEST_TEMPLATE.md | 3 +
core/connectors/sdk/src/lib.rs | 2 +-
core/connectors/sinks/iceberg_sink/README.md | 51 +-
core/connectors/sinks/iceberg_sink/src/lib.rs | 2 +-
.../sinks/iceberg_sink/src/router/commit.rs | 420 ++--
.../iceberg_sink/src/router/dynamic_router.rs | 326 +--
.../sinks/iceberg_sink/src/router/mod.rs | 173 +-
.../sinks/iceberg_sink/src/router/redelivery.rs | 358 ++--
.../sinks/iceberg_sink/src/router/static_router.rs | 198 +-
core/connectors/sinks/iceberg_sink/src/sink.rs | 36 +-
foreign/node/src/wire/message/header.utils.test.ts | 56 +
foreign/node/src/wire/message/header.utils.ts | 16 +
gateways/kafka/README.md | 41 +-
gateways/kafka/docs/BRIDGE_MAPPING.md | 14 +-
gateways/kafka/docs/CONFIGS.md | 551 ++++--
gateways/kafka/docs/SCOPE.md | 10 +-
gateways/kafka/docs/TEST_SUITE.md | 10 +-
gateways/kafka/src/bridge/config.rs | 22 +-
gateways/kafka/src/bridge/error.rs | 16 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 46 +-
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 119 +-
gateways/kafka/src/bridge/mod.rs | 5 +
gateways/kafka/src/bridge/nodes.rs | 36 +-
gateways/kafka/src/bridge/topic_settings.rs | 822 ++++++++
gateways/kafka/src/protocol/api.rs | 26 +
gateways/kafka/src/protocol/auto_topic_creation.rs | 2 +-
.../kafka/src/protocol/handlers/alter_configs.rs | 140 +-
.../src/protocol/handlers/create_partitions.rs | 555 +++++-
.../kafka/src/protocol/handlers/create_topics.rs | 385 +++-
.../src/protocol/handlers/describe_configs.rs | 427 ++--
.../protocol/handlers/incremental_alter_configs.rs | 108 +-
gateways/kafka/src/protocol/handlers/metadata.rs | 170 +-
.../kafka/src/protocol/handlers/topic_config.rs | 2081 ++++++++++++++++----
.../src/protocol/handlers/topic_config/keys.rs | 1594 +++++++++++++++
.../kafka/tests/bridge_iggy_integration_tests.rs | 10 +-
gateways/kafka/tests/common/iggy_server.rs | 4 +-
gateways/kafka/tests/configs_java_client_tests.rs | 12 +
gateways/kafka/tests/configs_real_bridge_tests.rs | 677 ++++++-
.../kafka/tests/create_topics_real_bridge_tests.rs | 371 +++-
gateways/kafka/tests/java/ConfigsProbe.java | 46 +
gateways/kafka/tests/kafka_client_e2e_tests.rs | 288 ++-
.../tests/replication_factor_cluster_tests.rs | 212 ++
48 files changed, 8749 insertions(+), 1885 deletions(-)
create mode 100644 gateways/kafka/src/bridge/topic_settings.rs
create mode 100644 gateways/kafka/src/protocol/handlers/topic_config/keys.rs
create mode 100644 gateways/kafka/tests/replication_factor_cluster_tests.rs
