This is an automated email from the ASF dual-hosted git repository.
ryerraguntla pushed a change to branch feat/gateways-3546-delete-topics-only
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 6e1ffcfdb Fixing the merge issues
omit 3e8c95912 Merge branch 'master' into
feat/gateways-3546-delete-topics-only
omit b71936686 Fixing doc test and validated clippy with newer version of
clippy
omit 657228341 Fixing review comments
omit fa57ee6f5 Fixing team review skill
omit f5a198fdc feat(gateways): fix the wire fixures.sh)
omit 1a0acc49b Updating after quick review
omit 26a4d67b7 adding boound guards and end to end tests
omit 8afc2c8e0 Initial version of Delete Topics implementation
add 2eac34938 test(server): expect per-topic size and message count on
/metrics (#4475)
add 875699426 ci(repo): move jobs off ubuntu-latest to cut runner queue
time (#4479)
add 5753d4958 refactor!: remove the purge API and its server machinery
(#4477)
add 5ded8ff62 feat(configs): list configuration environment variables
(#4350)
add b7576e580 chore(deps): Bump cucumber-cpp from 0.8.0.bcr.1 to 0.9.0 in
/foreign/cpp in the cpp group across 1 directory (#4469)
add 69a1bcc16 chore(deps): Bump the node group across 1 directory with 12
updates (#4470)
add ed7e251dc chore(deps): Bump the csharp group with 2 updates (#4406)
add 8efc3e1e6 chore(deps): Bump the python group across 3 directories with
3 updates (#4435)
add 9536916bd feat(csharp): implement connection string parsing (#4363)
add 89921bf48 docs(repo): add the RFC process and template (#4385)
add b4e357cc9 chore(deps): Bump the web group across 1 directory with 8
updates (#4468)
add 09183950a feat(connectors): add Google BigQuery sink connector (#4394)
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 60d621ad2 test(integration): add chaos monkey to catch data loss under
node kills (#4407)
add bbdc54ccc fix(cli): resolve server address for ws transport (#4482)
add c5f21c0c2 perf(connectors): drain field_mappings instead of
clone-then-clear (#4362)
add 2661b5ed4 feat(gateways): Kafka Gateway add DeleteTopics API key that
deletes the Iggy topic only
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6e1ffcfdb)
\
N -- N -- N refs/heads/feat/gateways-3546-delete-topics-only
(2661b5ed4)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-sdk/SKILL.md | 2 +-
.config/nextest.toml | 8 +
.github/actions/php/pre-merge/action.yml | 16 +-
.github/actions/rust/pre-merge/action.yml | 3 +
.github/actions/utils/setup-swift/action.yml | 55 +-
.github/workflows/_build_python_wheels.yml | 12 +-
.github/workflows/_build_rust_artifacts.yml | 17 +-
.github/workflows/_common.yml | 32 +-
.github/workflows/_detect.yml | 2 +-
.github/workflows/_publish_rust_crates.yml | 2 +-
.github/workflows/_test.yml | 4 +-
.github/workflows/_test_bdd.yml | 2 +-
.github/workflows/_test_examples.yml | 14 +-
.github/workflows/codecov-notify.yml | 2 +-
.github/workflows/coverage-baseline.yml | 18 +-
.github/workflows/edge-release.yml | 2 +-
.github/workflows/issue-labeler-assigner.yml | 2 +-
.github/workflows/post-merge.yml | 4 +-
.github/workflows/pr-skill-review-post.yml | 2 +-
.github/workflows/pr-skill-review-run.yml | 2 +-
.github/workflows/pr-title.yml | 3 +-
.github/workflows/pr-triage-apply.yml | 2 +-
.github/workflows/pr-triage-collect.yml | 2 +-
.github/workflows/pre-merge.yml | 2 +-
.github/workflows/publish.yml | 20 +-
.github/workflows/stale-prs-unmark-on-activity.yml | 2 +-
.github/workflows/stale-prs-unmark.yml | 2 +-
.github/workflows/stale-prs.yml | 2 +-
CONTRIBUTING.md | 5 +
Cargo.lock | 146 +-
Cargo.toml | 13 +
bdd/python/uv.lock | 70 +-
core/ai/mcp/Cargo.toml | 1 +
core/ai/mcp/README.md | 6 +-
core/ai/mcp/src/error.rs | 2 +
core/ai/mcp/src/main.rs | 34 +-
core/ai/mcp/src/service/mod.rs | 25 -
core/ai/mcp/src/service/requests.rs | 15 -
core/binary_protocol/src/codes.rs | 8 +-
core/binary_protocol/src/consensus/error.rs | 8 +-
core/binary_protocol/src/consensus/operation.rs | 31 +-
core/binary_protocol/src/dispatch.rs | 68 +-
core/binary_protocol/src/requests/streams/mod.rs | 2 -
.../src/requests/streams/purge_stream.rs | 60 -
core/binary_protocol/src/requests/topics/mod.rs | 2 -
.../src/requests/topics/purge_topic.rs | 86 -
core/binary_protocol/src/responses/streams/mod.rs | 2 -
.../src/responses/streams/purge_stream.rs | 19 -
core/binary_protocol/src/responses/topics/mod.rs | 2 -
.../src/responses/topics/purge_topic.rs | 19 -
core/cli/src/args/stream.rs | 18 -
core/cli/src/args/topic.rs | 27 -
core/cli/src/args/user.rs | 20 +-
core/cli/src/commands/binary_streams/mod.rs | 1 -
.../src/commands/binary_streams/purge_stream.rs | 59 -
core/cli/src/commands/binary_topics/mod.rs | 1 -
core/cli/src/commands/binary_topics/purge_topic.rs | 67 -
core/cli/src/credentials.rs | 42 +-
core/cli/src/error.rs | 6 -
core/cli/src/main.rs | 36 +-
core/common/src/http/streams/mod.rs | 1 -
core/common/src/http/streams/purge_stream.rs | 37 -
core/common/src/http/topics/mod.rs | 1 -
core/common/src/http/topics/purge_topic.rs | 41 -
core/common/src/traits/binary_impls/streams.rs | 16 +-
core/common/src/traits/binary_impls/topics.rs | 26 +-
core/common/src/traits/consumer_offset_client.rs | 4 -
core/common/src/traits/stream_client.rs | 4 -
core/common/src/traits/topic_client.rs | 8 -
core/common/src/types/args/mod.rs | 60 +-
core/configs/src/configs_impl/env_listing.rs | 102 +
core/configs/src/configs_impl/env_mapping.rs | 111 +
core/configs/src/configs_impl/file_provider.rs | 23 +-
core/configs/src/configs_impl/mod.rs | 9 +-
.../configs/src/configs_impl/typed_env_provider.rs | 41 +-
core/configs/src/lib.rs | 5 +-
core/configs/src/server_config/cluster.rs | 19 +
core/configs/src/server_config/server.rs | 68 +-
core/configs_derive/src/config_env.rs | 225 +-
core/connectors/runtime/README.md | 4 +
.../example_config/connectors/bigquery_sink.toml | 63 +
core/connectors/runtime/src/configs/connectors.rs | 2 +-
.../src/configs/connectors/local_provider.rs | 27 +-
core/connectors/runtime/src/error.rs | 4 +
core/connectors/runtime/src/main.rs | 106 +-
core/connectors/runtime/src/source.rs | 4 +-
core/connectors/sdk/README.md | 2 +
core/connectors/sdk/src/convert.rs | 287 +-
core/connectors/sdk/src/decoders/avro.rs | 35 +-
core/connectors/sdk/src/decoders/flatbuffer.rs | 35 +-
core/connectors/sdk/src/decoders/proto.rs | 64 +-
core/connectors/sdk/src/encoders/avro.rs | 54 +-
core/connectors/sdk/src/encoders/flatbuffer.rs | 48 +-
core/connectors/sdk/src/encoders/proto.rs | 91 +-
core/connectors/sdk/src/retry.rs | 195 +-
core/connectors/sdk/src/transforms/avro_convert.rs | 36 +-
.../connectors/sdk/src/transforms/proto_convert.rs | 31 +-
.../connectors/sdk/tests/flatbuffer_integration.rs | 16 +
core/connectors/sinks/README.md | 1 +
.../{influxdb_sink => bigquery_sink}/Cargo.toml | 26 +-
core/connectors/sinks/bigquery_sink/README.md | 263 ++
core/connectors/sinks/bigquery_sink/config.toml | 63 +
core/connectors/sinks/bigquery_sink/src/client.rs | 445 +++
core/connectors/sinks/bigquery_sink/src/encode.rs | 2129 +++++++++++
core/connectors/sinks/bigquery_sink/src/error.rs | 210 ++
core/connectors/sinks/bigquery_sink/src/lib.rs | 534 +++
core/connectors/sinks/bigquery_sink/src/schema.rs | 866 +++++
core/connectors/sinks/bigquery_sink/src/sink.rs | 407 +++
.../sinks/bigquery_sink/tests/bigquery_sink.rs | 566 +++
.../sinks/bigquery_sink/tests/common/mod.rs | 393 +++
core/connectors/sinks/influxdb_sink/README.md | 5 +-
core/connectors/sinks/quickwit_sink/README.md | 4 +-
core/connectors/sources/influxdb_source/README.md | 4 +-
core/consensus/src/impls.rs | 29 +-
core/consensus/src/observability.rs | 2 -
core/consensus/src/state_manifest.rs | 5 +-
core/integration/src/harness/config/resolve.rs | 15 +-
core/integration/src/harness/config/server.rs | 10 +
core/integration/src/harness/disk.rs | 177 +-
core/integration/src/harness/handle/server.rs | 223 +-
core/integration/tests/cli/common/mod.rs | 41 +
core/integration/tests/cli/general/mod.rs | 1 +
...ng_credentials.rs => test_unknown_transport.rs} | 34 +-
.../test_pat_create_command.rs | 17 +-
.../test_pat_delete_command.rs | 15 +-
core/integration/tests/cli/stream/mod.rs | 1 -
.../tests/cli/stream/test_stream_help_command.rs | 1 -
.../tests/cli/stream/test_stream_purge_command.rs | 223 --
core/integration/tests/cli/system/mod.rs | 2 +
.../tests/cli/system/test_cli_session_scenario.rs | 42 +-
.../tests/cli/system/test_me_command.rs | 36 +-
...st_logout_cmd.rs => test_session_status_cmd.rs} | 49 +-
core/integration/tests/cli/topic/mod.rs | 1 -
.../tests/cli/topic/test_topic_help_command.rs | 1 -
.../tests/cli/topic/test_topic_purge_command.rs | 295 --
.../cli/user/test_user_permissions_command.rs | 59 +-
core/integration/tests/cluster/chaos_monkey.rs | 2614 ++++++++++++++
.../tests/cluster/chaos_monkey/report.rs | 151 +
.../tests/cluster/consumer_offset_quota.rs | 74 +-
core/integration/tests/cluster/mod.rs | 1 +
core/integration/tests/cluster/partition_dedup.rs | 42 +-
core/integration/tests/config_env_listing/mod.rs | 312 ++
.../tests/data_integrity/storage_compat.rs | 264 +-
core/integration/tests/mcp/mod.rs | 24 +-
core/integration/tests/mod.rs | 28 +-
core/integration/tests/sdk/consumer_offset.rs | 2 -
core/integration/tests/sdk/mod.rs | 1 +
core/integration/tests/sdk/stream_builder.rs | 70 +
.../server/{purge_delete.rs => delete_segments.rs} | 22 +-
.../tests/server/descriptor_exhaustion_vsr.rs | 4 +-
core/integration/tests/server/http_vsr.rs | 40 +
core/integration/tests/server/mod.rs | 11 +-
core/integration/tests/server/purge_vsr.rs | 142 -
core/integration/tests/server/raw_tcp.rs | 18 +-
.../server/scenarios/authentication_scenario.rs | 2 -
...ete_scenario.rs => delete_segments_scenario.rs} | 464 ---
.../scenarios/delete_stats_rollback_scenario.rs | 8 +-
core/integration/tests/server/scenarios/mod.rs | 4 +-
.../stale_client_consumer_group_scenario.rs | 3 +-
.../scenarios/stream_size_validation_scenario.rs | 52 +-
.../tests/server/scenarios/system_scenario.rs | 78 -
core/integration/tests/server/topic_metrics_vsr.rs | 114 +
core/integration/tests/server/unknown_code_vsr.rs | 136 +-
core/journal/src/partition_journal.rs | 260 +-
core/journal/src/partition_journal/segments.rs | 17 +-
.../src/permissioner/permissioner_rules/streams.rs | 4 -
.../src/permissioner/permissioner_rules/topics.rs | 9 -
core/metadata/src/stm/authz.rs | 26 +-
core/metadata/src/stm/result.rs | 26 +-
core/metadata/src/stm/snapshot.rs | 13 +-
core/metadata/src/stm/stream.rs | 602 +---
core/partitions/Cargo.toml | 1 -
core/partitions/src/iggy_partition.rs | 3730 ++++----------------
core/partitions/src/iggy_partitions.rs | 9 +-
core/partitions/src/io.rs | 88 +-
core/partitions/src/journal.rs | 85 +-
core/partitions/src/lib.rs | 2 +-
core/partitions/src/log.rs | 28 +-
core/partitions/src/offset_storage.rs | 242 +-
core/partitions/src/persistence.rs | 28 -
core/partitions/src/poll_plan.rs | 14 +-
core/partitions/src/state_transfer.rs | 231 +-
core/partitions/tests/consumer_offset_history.rs | 719 ----
.../src/client_wrappers/binary_stream_client.rs | 10 -
.../sdk/src/client_wrappers/binary_topic_client.rs | 14 -
core/sdk/src/clients/binary_streams.rs | 4 -
core/sdk/src/clients/binary_topics.rs | 12 -
core/sdk/src/clients/client.rs | 19 +-
core/sdk/src/clients/consumer.rs | 44 +-
core/sdk/src/clients/producer.rs | 57 +-
core/sdk/src/http/streams.rs | 9 -
core/sdk/src/http/topics.rs | 13 -
core/sdk/src/poll_routing.rs | 4 +-
.../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 +-
core/server/README.md | 8 +-
core/server/server.http | 8 -
core/server/src/args.rs | 39 +
core/server/src/boot/mod.rs | 44 +-
core/server/src/consumer_group.rs | 2 +-
core/server/src/dispatch/authz.rs | 2 -
core/server/src/dispatch/failure.rs | 137 +-
core/server/src/dispatch/mod.rs | 158 +-
core/server/src/dispatch/partition.rs | 171 +-
core/server/src/dispatch/test_support.rs | 4 +
core/server/src/http.rs | 11 +-
core/server/src/http/handlers.rs | 50 +-
core/server/src/http/metrics.rs | 2 +-
core/server/src/http/submit.rs | 2 +-
core/server/src/main.rs | 17 +-
core/server/src/partition_helpers.rs | 14 +-
core/server/src/partition_reconciler.rs | 329 +-
core/server/src/server_error.rs | 4 +-
core/server_common/src/consensus_message.rs | 12 +-
core/shard/src/lib.rs | 221 +-
core/shard/src/metrics.rs | 32 +-
core/shard/src/partition_io.rs | 264 +-
core/shard/src/poll.rs | 26 +-
core/shard/src/poll/completion_tests.rs | 76 +-
core/shard/src/router.rs | 122 +-
core/simulator/src/client.rs | 24 +-
.../simulator/src/consumer_offset_history_tests.rs | 219 --
core/simulator/src/lib.rs | 3 -
core/simulator/src/storage.rs | 2 +-
core/simulator/src/storage/bookmark_recovery.rs | 360 ++
core/simulator/src/storage/purge.rs | 758 ----
core/simulator/src/storage/tests.rs | 107 +-
core/simulator/src/workload/actions.rs | 4 +-
core/simulator/src/workload/ops/mod.rs | 4 -
core/simulator/src/workload/ops/purge_stream.rs | 74 -
core/simulator/src/workload/ops/purge_topic.rs | 83 -
core/simulator/src/workload/options.rs | 6 +-
examples/python/pyproject.toml | 4 +-
examples/python/uv.lock | 68 +-
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 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/MODULE.bazel.lock | 4 +-
foreign/cpp/include/iggy.hpp | 28 -
foreign/cpp/src/client.cpp | 8 -
foreign/cpp/src/client.rs | 37 -
foreign/cpp/src/lib.rs | 2 -
foreign/cpp/tests/e2e/stream.cpp | 372 --
foreign/cpp/tests/e2e/topic.cpp | 331 --
foreign/cpp/tests/unit/unit_tests.cpp | 2 -
foreign/csharp/Directory.Packages.props | 4 +-
.../ConnectionStringTests.cs | 104 +
.../Helpers/Eventually.cs | 43 -
.../IggyTlsConnectionTests.cs | 16 +
.../Iggy_SDK.Tests.Integration/StreamsTests.cs | 32 -
.../Iggy_SDK.Tests.Integration/TopicsTests.cs | 32 -
.../Iggy_SDK/Configuration/ConnectionString.cs | 250 ++
.../Configuration/IggyClientConfigurator.cs | 38 +
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 7 -
.../csharp/Iggy_SDK/Factory/IggyClientFactory.cs | 21 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs | 12 -
foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs | 13 -
.../Implementations/HttpMessageStream.cs | 20 -
.../IggyClient/Implementations/TcpMessageStream.cs | 15 -
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 2 -
.../csharp/Iggy_SDK/Utils/IggyDurationParser.cs | 394 +++
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 10 +-
.../ClientTests/ConnectionStringTests.cs | 441 +++
.../ClientTests/HttpTopicOptionsTests.cs | 17 -
.../UtilityTests/IggyDurationParserTests.cs | 227 ++
.../Iggy_SDK_Tests/VsrTests/VsrOperationTests.cs | 6 +-
foreign/csharp/README.md | 45 +
foreign/go/client/tcp/tcp_poll_routing_test.go | 4 +-
foreign/go/internal/command/code.go | 2 -
foreign/go/internal/vsr/header_test.go | 1 -
foreign/go/internal/vsr/operation.go | 6 -
foreign/go/internal/vsr/operation_test.go | 6 +-
foreign/go/internal/vsr/protocol_parity_test.go | 2 -
.../iggy/client/async/tcp/vsr/VsrOperation.java | 8 +-
.../java/org/apache/iggy/serde/CommandCode.java | 3 +-
foreign/node/package-lock.json | 197 +-
foreign/node/package.json | 2 +-
foreign/node/src/e2e/tcp.stream.e2e.ts | 4 -
foreign/node/src/e2e/tcp.topic.e2e.ts | 4 -
foreign/node/src/wire/command-set.ts | 4 -
foreign/node/src/wire/command.code.ts | 2 -
foreign/node/src/wire/stream/index.ts | 1 -
.../node/src/wire/stream/purge-stream.command.ts | 49 -
foreign/node/src/wire/topic/index.ts | 1 -
foreign/node/src/wire/topic/purge-topic.command.ts | 54 -
foreign/node/src/wire/vsr/operation.test.ts | 4 +-
foreign/node/src/wire/vsr/operation.ts | 4 -
foreign/python/apache_iggy.pyi | 40 -
foreign/python/src/client.rs | 65 -
foreign/python/tests/test_stream.py | 97 +-
foreign/python/tests/test_topic.py | 119 -
foreign/python/uv.lock | 64 +-
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 2 -
foreign/swift/Tools/golden-vectors/src/main.rs | 18 +-
gateways/kafka/README.md | 44 +-
gateways/kafka/docs/CONFIGS.md | 109 +
gateways/kafka/docs/MANUAL_TESTING.md | 4 +-
gateways/kafka/docs/SCOPE.md | 19 +-
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 | 30 +-
gateways/kafka/src/protocol/bounds_guard.rs | 141 +-
.../kafka/src/protocol/handlers/alter_configs.rs | 389 ++
.../kafka/src/protocol/handlers/create_topics.rs | 73 +-
.../kafka/src/protocol/handlers/delete_topics.rs | 2 +-
.../src/protocol/handlers/describe_configs.rs | 480 +++
gateways/kafka/src/protocol/handlers/fetch.rs | 7 +-
gateways/kafka/src/protocol/handlers/mod.rs | 17 +-
.../kafka/src/protocol/handlers/topic_config.rs | 514 +++
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 | 33 +-
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 16 +-
gateways/kafka/tests/java/ConfigsProbe.java | 129 +
gateways/kafka/tests/sasl_tests.rs | 6 +-
gateways/kafka/tests/version_firewall_tests.rs | 96 +-
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 +-
rfcs/README.md | 250 ++
rfcs/rfc-template.md | 74 +
web/README.md | 2 +-
web/eslint.config.js | 4 +-
web/package-lock.json | 1036 ++----
web/package.json | 23 +-
web/src/ambient.d.ts | 2 +-
.../frontend/src/hooks/mod.rs => web/src/env.ts | 6 +-
web/src/hooks.client.ts | 2 +-
web/src/lib/api/ApiSchema.ts | 4 +-
web/src/lib/api/clientApi.ts | 18 +-
web/src/lib/api/fetchApi.ts | 8 +-
web/src/lib/api/fetchRouteApi.ts | 6 +-
web/src/lib/api/handleFetchErrors.ts | 18 +-
web/src/lib/auth/authStore.svelte.ts | 8 +-
web/src/lib/components/Breadcrumbs.svelte | 12 +-
web/src/lib/components/Button.svelte | 2 +-
web/src/lib/components/Combobox.svelte | 2 +-
.../components/DeleteButtonWithConfirmation.svelte | 2 +-
.../components/DropdownMenu/DropdownMenu.svelte | 2 +-
web/src/lib/components/DurationInput.svelte | 2 +-
web/src/lib/components/Header.svelte | 6 +-
.../lib/components/Layouts/SettingsLayout.svelte | 12 +-
web/src/lib/components/LoadingIndicator.svelte | 4 +-
web/src/lib/components/Logo/Logo.svelte | 10 +-
.../MessageDecoder/MessageDecoder.svelte | 2 +-
.../decoders/BuiltInDecoders/jsonDecoder.ts | 2 +-
web/src/lib/components/ModalConfirmation.svelte | 2 +-
.../components/Modals/AddPartitionsModal.svelte | 6 +-
.../lib/components/Modals/AddStreamModal.svelte | 4 +-
web/src/lib/components/Modals/AddTopicModal.svelte | 8 +-
web/src/lib/components/Modals/AddUserModal.svelte | 6 +-
web/src/lib/components/Modals/AppModals.svelte | 4 +-
.../components/Modals/DeletePartitionsModal.svelte | 8 +-
.../lib/components/Modals/DeleteUserModal.svelte | 2 +-
web/src/lib/components/Modals/EditUserModal.svelte | 2 +-
.../Modals/EditUserPermissionsModal.svelte | 2 +-
.../lib/components/Modals/InspectMessage.svelte | 8 +-
web/src/lib/components/Modals/ModalBase.svelte | 2 +-
.../components/Modals/StreamSettingsModal.svelte | 14 +-
.../components/Modals/TopicSettingsModal.svelte | 12 +-
web/src/lib/components/Navbar.svelte | 23 +-
web/src/lib/components/Paginator.svelte | 4 +-
web/src/lib/components/PasswordInput.svelte | 2 +-
web/src/lib/components/PeriodicInvalidator.svelte | 6 +-
web/src/lib/components/PermissionsManager.svelte | 12 +-
.../RouteComponents/Settings/UsersTab.svelte | 16 +-
.../Settings/UsersTabActions.svelte | 4 +-
web/src/lib/components/SlimSortableList.svelte | 2 +-
web/src/lib/components/SortableList.svelte | 9 +-
web/src/lib/components/StopPropagation.svelte | 2 +-
web/src/lib/components/ThemeController.svelte | 4 +-
web/src/lib/domain/Message.ts | 2 +-
web/src/lib/domain/Partition.ts | 2 +-
web/src/lib/domain/Stats.ts | 2 +-
web/src/lib/domain/Topic.ts | 6 +-
web/src/lib/domain/User.ts | 2 +-
web/src/lib/hooks/useGoPrev.ts | 10 +-
web/src/lib/types/appRoutes.ts | 4 +-
.../utils/base64Utils.test.mjs => params.test.mjs} | 18 +-
.../frontend/src/hooks/mod.rs => web/src/params.ts | 6 +-
web/src/params/i32.ts | 20 -
web/src/routes/+layout.svelte | 4 +-
web/src/routes/+layout.ts | 27 +-
web/src/routes/auth/+layout.svelte | 2 +-
web/src/routes/auth/logout/+page.svelte | 6 +-
web/src/routes/auth/sign-in/+page.svelte | 22 +-
web/src/routes/auth/sign-in/+page.ts | 8 +-
web/src/routes/dashboard/+layout.svelte | 8 +-
web/src/routes/dashboard/+layout.ts | 12 +-
web/src/routes/dashboard/overview/+page.ts | 4 +-
.../routes/dashboard/settings/server/+page.svelte | 8 +-
web/src/routes/dashboard/settings/server/+page.ts | 4 +-
.../dashboard/settings/terminal/+page.svelte | 2 +-
.../routes/dashboard/settings/users/+page.svelte | 18 +-
web/src/routes/dashboard/settings/users/+page.ts | 8 +-
.../routes/dashboard/settings/webUI/+page.svelte | 10 +-
web/src/routes/dashboard/streams/+layout.svelte | 17 +-
web/src/routes/dashboard/streams/+layout.ts | 4 +-
.../dashboard/streams/[streamId=i32]/+page.svelte | 14 +-
.../dashboard/streams/[streamId=i32]/+page.ts | 4 +-
.../streams/[streamId=i32]/topics/+page.svelte | 4 +-
.../topics/[topicId=i32]/+page.svelte | 18 +-
.../[streamId=i32]/topics/[topicId=i32]/+page.ts | 4 +-
.../partitions/[partitionId=i32]/+page.svelte | 4 +-
.../[partitionId=i32]/messages/+page.svelte | 25 +-
.../partitions/[partitionId=i32]/messages/+page.ts | 6 +-
web/svelte.config.js | 46 -
web/tsconfig.json | 15 +-
web/vite.config.ts | 31 +-
418 files changed, 19860 insertions(+), 14020 deletions(-)
delete mode 100644 core/binary_protocol/src/requests/streams/purge_stream.rs
delete mode 100644 core/binary_protocol/src/requests/topics/purge_topic.rs
delete mode 100644 core/binary_protocol/src/responses/streams/purge_stream.rs
delete mode 100644 core/binary_protocol/src/responses/topics/purge_topic.rs
delete mode 100644 core/cli/src/commands/binary_streams/purge_stream.rs
delete mode 100644 core/cli/src/commands/binary_topics/purge_topic.rs
delete mode 100644 core/common/src/http/streams/purge_stream.rs
delete mode 100644 core/common/src/http/topics/purge_topic.rs
create mode 100644 core/configs/src/configs_impl/env_listing.rs
create mode 100644
core/connectors/runtime/example_config/connectors/bigquery_sink.toml
copy core/connectors/sinks/{influxdb_sink => bigquery_sink}/Cargo.toml (71%)
create mode 100644 core/connectors/sinks/bigquery_sink/README.md
create mode 100644 core/connectors/sinks/bigquery_sink/config.toml
create mode 100644 core/connectors/sinks/bigquery_sink/src/client.rs
create mode 100644 core/connectors/sinks/bigquery_sink/src/encode.rs
create mode 100644 core/connectors/sinks/bigquery_sink/src/error.rs
create mode 100644 core/connectors/sinks/bigquery_sink/src/lib.rs
create mode 100644 core/connectors/sinks/bigquery_sink/src/schema.rs
create mode 100644 core/connectors/sinks/bigquery_sink/src/sink.rs
create mode 100644 core/connectors/sinks/bigquery_sink/tests/bigquery_sink.rs
create mode 100644 core/connectors/sinks/bigquery_sink/tests/common/mod.rs
copy core/integration/tests/cli/general/{test_missing_credentials.rs =>
test_unknown_transport.rs} (67%)
delete mode 100644
core/integration/tests/cli/stream/test_stream_purge_command.rs
copy core/integration/tests/cli/system/{test_logout_cmd.rs =>
test_session_status_cmd.rs} (57%)
delete mode 100644 core/integration/tests/cli/topic/test_topic_purge_command.rs
create mode 100644 core/integration/tests/cluster/chaos_monkey.rs
create mode 100644 core/integration/tests/cluster/chaos_monkey/report.rs
create mode 100644 core/integration/tests/config_env_listing/mod.rs
create mode 100644 core/integration/tests/sdk/stream_builder.rs
rename core/integration/tests/server/{purge_delete.rs => delete_segments.rs}
(68%)
delete mode 100644 core/integration/tests/server/purge_vsr.rs
rename core/integration/tests/server/scenarios/{purge_delete_scenario.rs =>
delete_segments_scenario.rs} (68%)
create mode 100644 core/integration/tests/server/topic_metrics_vsr.rs
delete mode 100644 core/partitions/tests/consumer_offset_history.rs
delete mode 100644 core/simulator/src/consumer_offset_history_tests.rs
create mode 100644 core/simulator/src/storage/bookmark_recovery.rs
delete mode 100644 core/simulator/src/storage/purge.rs
delete mode 100644 core/simulator/src/workload/ops/purge_stream.rs
delete mode 100644 core/simulator/src/workload/ops/purge_topic.rs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/ConnectionStringTests.cs
delete mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Helpers/Eventually.cs
create mode 100644 foreign/csharp/Iggy_SDK/Configuration/ConnectionString.cs
create mode 100644 foreign/csharp/Iggy_SDK/Utils/IggyDurationParser.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/ClientTests/ConnectionStringTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/UtilityTests/IggyDurationParserTests.cs
delete mode 100644 foreign/node/src/wire/stream/purge-stream.command.ts
delete mode 100644 foreign/node/src/wire/topic/purge-topic.command.ts
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
create mode 100644 rfcs/README.md
create mode 100644 rfcs/rfc-template.md
copy core/bench/dashboard/frontend/src/hooks/mod.rs => web/src/env.ts (82%)
copy web/src/{lib/utils/base64Utils.test.mjs => params.test.mjs} (60%)
copy core/bench/dashboard/frontend/src/hooks/mod.rs => web/src/params.ts (83%)
delete mode 100644 web/src/params/i32.ts
delete mode 100644 web/svelte.config.js
