This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch cluster-chaos-monkey
in repository https://gitbox.apache.org/repos/asf/iggy.git
from cd6e7afce test(cluster): preserve chaos run reports and restart logs
add 7da163362 fix(sdk): removes topic_id and stream_id from public Stream
API (#4249)
add 46caa7c82 fix(connectors): honor Retry-After on every retried status
(#4192)
add a029d4db4 fix(cli): fix help text of user permissions -g and -s (#4484)
add 5f34dbc01 feat(gateways): Kafka Gateway add DescribeConfigs and
AlterConfigs APIs (#4398)
add 8e11e42b4 Merge branch 'master' into cluster-chaos-monkey
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-sdk/SKILL.md | 2 +-
core/cli/src/args/user.rs | 20 +-
core/connectors/runtime/src/source.rs | 4 +-
core/connectors/sdk/README.md | 2 +
core/connectors/sdk/src/retry.rs | 195 +++++--
core/connectors/sinks/influxdb_sink/README.md | 5 +-
core/connectors/sinks/quickwit_sink/README.md | 4 +-
core/connectors/sources/influxdb_source/README.md | 4 +-
.../cli/user/test_user_permissions_command.rs | 59 +-
core/integration/tests/sdk/consumer_offset.rs | 2 -
core/integration/tests/sdk/mod.rs | 1 +
core/integration/tests/sdk/stream_builder.rs | 70 +++
core/sdk/src/clients/client.rs | 15 +-
core/sdk/src/clients/consumer.rs | 44 +-
core/sdk/src/clients/producer.rs | 57 +-
.../src/stream_builder/build/build_stream_topic.rs | 42 +-
.../stream_builder/config/config_iggy_consumer.rs | 58 +-
.../stream_builder/config/config_iggy_producer.rs | 57 +-
.../stream_builder/config/config_iggy_stream.rs | 32 +-
examples/rust/src/shared/system.rs | 10 +-
.../rust/src/stream-builder/stream-basic/main.rs | 3 +-
.../stream-builder/stream-consumer-config/main.rs | 6 +-
.../stream-builder/stream-producer-config/main.rs | 6 +-
gateways/kafka/README.md | 34 +-
gateways/kafka/docs/CONFIGS.md | 109 ++++
gateways/kafka/docs/MANUAL_TESTING.md | 6 +-
gateways/kafka/docs/SCOPE.md | 22 +-
gateways/kafka/scripts/ci-wire-fixtures.sh | 2 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 12 +-
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 166 +++++-
gateways/kafka/src/bridge/mod.rs | 11 +-
gateways/kafka/src/protocol/api.rs | 39 +-
gateways/kafka/src/protocol/bounds_guard.rs | 141 ++++-
.../kafka/src/protocol/handlers/alter_configs.rs | 389 +++++++++++++
.../kafka/src/protocol/handlers/create_topics.rs | 80 +--
.../src/protocol/handlers/describe_configs.rs | 480 +++++++++++++++
gateways/kafka/src/protocol/handlers/mod.rs | 19 +-
.../kafka/src/protocol/handlers/topic_config.rs | 514 +++++++++++++++++
gateways/kafka/src/server.rs | 3 +
gateways/kafka/tests/common/scope.rs | 2 +
gateways/kafka/tests/common/wire.rs | 51 +-
gateways/kafka/tests/configs_handler_tests.rs | 212 +++++++
gateways/kafka/tests/configs_java_client_tests.rs | 310 ++++++++++
gateways/kafka/tests/configs_real_bridge_tests.rs | 642 +++++++++++++++++++++
gateways/kafka/tests/fetch_real_bridge_tests.rs | 10 +-
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 16 +-
gateways/kafka/tests/java/ConfigsProbe.java | 129 +++++
gateways/kafka/tests/version_firewall_tests.rs | 91 ++-
gateways/kafka/tools/kafka-tool/README.md | 4 +-
gateways/kafka/tools/kafka-tool/src/main.rs | 10 +
gateways/kafka/tools/kafka-tool/src/response.rs | 38 +-
51 files changed, 3772 insertions(+), 468 deletions(-)
create mode 100644 core/integration/tests/sdk/stream_builder.rs
create mode 100644 gateways/kafka/docs/CONFIGS.md
create mode 100644 gateways/kafka/src/protocol/handlers/alter_configs.rs
create mode 100644 gateways/kafka/src/protocol/handlers/describe_configs.rs
create mode 100644 gateways/kafka/src/protocol/handlers/topic_config.rs
create mode 100644 gateways/kafka/tests/configs_handler_tests.rs
create mode 100644 gateways/kafka/tests/configs_java_client_tests.rs
create mode 100644 gateways/kafka/tests/configs_real_bridge_tests.rs
create mode 100644 gateways/kafka/tests/java/ConfigsProbe.java
