This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-4x-clients
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a3d1358ee fix(gateways): send and decode ApiVersions v5 in
kafka-message-gen
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 689436fbf feat(gateways): accept SaslHandshake v0 from older Kafka
clients (#4778)
add 00ea3f4ca Merge branch 'master' into kafka-4x-clients
No new revisions were added by this update.
Summary of changes:
.config/nextest.toml | 5 +-
core/kafka_wire/src/bounds_guard.rs | 10 +-
core/kafka_wire/src/sasl.rs | 97 +-
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/AUTHENTICATION.md | 15 +-
gateways/kafka/docs/BRIDGE_MAPPING.md | 14 +-
gateways/kafka/docs/CONFIGS.md | 551 ++++--
gateways/kafka/docs/MANUAL_TESTING.md | 30 +
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 | 44 +-
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 +++++++++++++++
gateways/kafka/src/server.rs | 251 ++-
.../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 ++
gateways/kafka/tests/sasl_tests.rs | 113 +-
39 files changed, 8098 insertions(+), 1313 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
