You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by hg...@apache.org on 2026/03/19 11:18:52 UTC
(iggy) branch skipping-offset updated (fb6d7bfdb -> b72fa14a6)
This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch skipping-offset
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard fb6d7bfdb Merge branch 'master' into skipping-offset
discard 513a6e342 Merge branch 'master' into skipping-offset
discard 1d05ba5ab fix(server): prevent consumer offset skip during concurrent produce+consume
add 68abb6056 refactor(java): harden client lifecycle and streamline test suite (#2959)
add b87a84f96 feat(rust): add wire protocol codec and types to binary_protocol crate (#2946)
add 79103ee4b feat(server): add threads count and disk space to sysinfo stats (#2917)
add c70ff9508 refactor(go): refactor WithTLS (#2957)
add a1045c3a3 fix(ci): prevent flaky keyring tests by keeping daemons alive (#2963)
add 19387f303 feat(rust): add wire types for all commands and zero-copy message primitives (#2962)
add 0102b50c3 fix(integration): reduce flakiness in connector integration tests (#2966)
add b45254f2d docs(go): solve typo in DeleteStream method. (#2972)
add 34280ab7b fix(sdk): fix broken Windows build for SDK and CLI (#2971)
add 9c8b5cc6c feat(bdd): add --coverage flag to run-bdd-tests.sh for all SDKs (#2950)
add b72fa14a6 fix(server): prevent consumer offset skip during produce+consume and after restart
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 (fb6d7bfdb)
\
N -- N -- N refs/heads/skipping-offset (b72fa14a6)
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:
.github/actions/rust/pre-merge/action.yml | 20 +-
.github/config/components.yml | 24 +-
.github/workflows/_test.yml | 1 +
.github/workflows/post-merge.yml | 11 +-
.typos.toml | 4 +-
Cargo.lock | 14 +-
Cargo.toml | 8 +-
DEPENDENCIES.md | 8 +-
bdd/docker-compose.coverage.yml | 91 +++
bdd/java/build.gradle.kts | 7 +
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 2 +-
bdd/python/pyproject.toml | 1 +
bdd/python/uv.lock | 142 +++-
core/binary_protocol/Cargo.toml | 13 +-
core/binary_protocol/src/codec.rs | 226 +++++++
core/binary_protocol/src/codes.rs | 221 ++++++
core/binary_protocol/src/consensus/command.rs | 67 ++
core/binary_protocol/src/consensus/error.rs | 64 ++
.../src}/consensus/header.rs | 693 ++++++++-----------
core/binary_protocol/src/consensus/message.rs | 338 ++++++++++
core/binary_protocol/src/consensus/mod.rs | 54 ++
core/binary_protocol/src/consensus/operation.rs | 221 ++++++
core/binary_protocol/src/error.rs | 50 ++
.../binary_protocol/src/frame.rs | 39 +-
core/binary_protocol/src/lib.rs | 84 ++-
core/binary_protocol/src/message_layout.rs | 56 ++
core/binary_protocol/src/message_view.rs | 614 +++++++++++++++++
core/binary_protocol/src/primitives/consumer.rs | 133 ++++
core/binary_protocol/src/primitives/identifier.rs | 402 +++++++++++
.../src/primitives}/mod.rs | 8 +-
.../binary_protocol/src/primitives/partitioning.rs | 271 ++++++++
core/binary_protocol/src/primitives/permissions.rs | 471 +++++++++++++
.../src/primitives/polling_strategy.rs | 196 ++++++
.../consumer_groups/create_consumer_group.rs | 126 ++++
.../consumer_groups/delete_consumer_group.rs | 110 +++
.../requests/consumer_groups/get_consumer_group.rs | 110 +++
.../consumer_groups/get_consumer_groups.rs | 102 +++
.../consumer_groups/join_consumer_group.rs | 110 +++
.../consumer_groups/leave_consumer_group.rs | 110 +++
.../src/requests/consumer_groups/mod.rs} | 29 +-
.../consumer_offsets/delete_consumer_offset.rs | 175 +++++
.../consumer_offsets/get_consumer_offset.rs | 175 +++++
.../src/requests/consumer_offsets}/mod.rs | 8 +-
.../consumer_offsets/store_consumer_offset.rs | 180 +++++
.../src/requests/messages/flush_unsaved_buffer.rs | 155 +++++
.../src/requests}/messages/mod.rs | 6 +
.../src/requests/messages/poll_messages.rs | 220 ++++++
.../src/requests/messages/send_messages.rs | 750 +++++++++++++++++++++
.../src/requests}/mod.rs | 14 +-
.../src/requests/partitions/create_partitions.rs | 118 ++++
.../src/requests/partitions/delete_partitions.rs | 118 ++++
.../src/requests/partitions}/mod.rs | 6 +-
.../create_personal_access_token.rs | 115 ++++
.../delete_personal_access_token.rs | 82 +++
.../get_personal_access_tokens.rs | 53 ++
.../login_with_personal_access_token.rs | 82 +++
.../src/requests/personal_access_tokens}/mod.rs | 11 +-
.../src/requests/segments/delete_segments.rs | 128 ++++
.../src/requests/segments}/mod.rs | 4 +-
.../src/requests/streams/create_stream.rs | 96 +++
.../src/requests/streams/delete_stream.rs | 60 ++
.../src/requests/streams/get_stream.rs | 80 +++
.../src/requests/streams/get_streams.rs} | 46 +-
.../src/requests/streams}/mod.rs | 14 +-
.../src/requests/streams/purge_stream.rs | 60 ++
.../src/requests/streams/update_stream.rs | 81 +++
.../src/requests/system/get_client.rs | 96 +++
.../src/requests/system/get_clients.rs} | 46 +-
.../src/requests/system/get_cluster_metadata.rs | 53 ++
.../src/requests/system/get_me.rs} | 47 +-
.../src/requests/system/get_snapshot.rs | 47 +-
.../src/requests/system/get_stats.rs} | 47 +-
.../src/requests/system}/mod.rs | 17 +-
.../src/requests/system/ping.rs} | 47 +-
.../src/requests/topics/create_topic.rs | 147 ++++
.../src/requests/topics/delete_topic.rs | 98 +++
.../src/requests/topics/get_topic.rs | 98 +++
.../src/requests/topics/get_topics.rs | 71 ++
.../src/requests/topics}/mod.rs | 14 +-
.../src/requests/topics/purge_topic.rs | 86 +++
.../src/requests/topics/update_topic.rs | 150 +++++
.../src/requests/users/change_password.rs | 131 ++++
.../src/requests/users/create_user.rs | 203 ++++++
.../src/requests/users/delete_user.rs | 71 ++
.../binary_protocol/src/requests/users/get_user.rs | 80 +++
.../src/requests/users/get_users.rs} | 47 +-
.../src/requests/users/login_user.rs | 220 ++++++
.../src/requests/users/logout_user.rs} | 46 +-
.../src/requests/users}/mod.rs | 20 +-
.../src/requests/users/update_permissions.rs | 160 +++++
.../src/requests/users/update_user.rs | 184 +++++
.../src/responses/clients/client_response.rs | 211 ++++++
.../src/responses/clients/get_client.rs | 143 ++++
.../src/responses/clients/get_clients.rs | 98 +++
.../src/responses/clients}/mod.rs | 8 +-
.../consumer_groups/consumer_group_response.rs | 132 ++++
.../consumer_groups/create_consumer_group.rs} | 7 +-
.../consumer_groups/delete_consumer_group.rs} | 7 +-
.../consumer_groups/get_consumer_group.rs | 210 ++++++
.../consumer_groups/get_consumer_groups.rs | 109 +++
.../consumer_groups/join_consumer_group.rs} | 7 +-
.../consumer_groups/leave_consumer_group.rs} | 7 +-
.../src/responses/consumer_groups/mod.rs | 39 +-
.../consumer_offsets/delete_consumer_offset.rs} | 7 +-
.../consumer_offsets/get_consumer_offset.rs | 114 ++++
.../src/responses/consumer_offsets}/mod.rs | 9 +-
.../consumer_offsets/store_consumer_offset.rs} | 7 +-
.../src/responses}/messages/mod.rs | 4 +-
.../src/responses/messages/poll_messages.rs | 176 +++++
.../src/responses/mod.rs} | 42 +-
.../create_personal_access_token.rs | 80 +++
.../delete_personal_access_token.rs} | 2 +-
.../get_personal_access_tokens.rs | 145 ++++
.../login_with_personal_access_token.rs} | 6 +-
.../src/responses/personal_access_tokens}/mod.rs | 20 +-
.../src/responses/streams/create_stream.rs} | 13 +-
.../src/responses/streams/delete_stream.rs} | 7 +-
.../src/responses/streams/get_stream.rs | 232 +++++++
.../src/responses/streams/get_streams.rs | 103 +++
.../src/responses/streams}/mod.rs | 18 +-
.../src/responses/streams/purge_stream.rs} | 7 +-
.../src/responses/streams/stream_response.rs | 142 ++++
.../src/responses/streams/update_stream.rs} | 7 +-
.../src/responses/system/get_stats.rs | 427 ++++++++++++
.../src/responses/system}/mod.rs | 7 +-
.../src/responses/system/ping.rs} | 2 +-
.../src/responses/topics/create_topic.rs} | 7 +-
.../src/responses/topics/delete_topic.rs} | 7 +-
.../src/responses/topics/get_topic.rs | 234 +++++++
.../src/responses/topics/get_topics.rs | 115 ++++
.../src/responses/topics}/mod.rs | 16 +-
.../src/responses/topics/purge_topic.rs} | 7 +-
.../src/responses/topics/update_topic.rs} | 7 +-
.../src/responses/users/change_password.rs} | 2 +-
.../src/responses/users/create_user.rs} | 2 +-
.../src/responses/users/delete_user.rs} | 2 +-
.../src/responses/users/get_user.rs | 205 ++++++
.../src/responses/users/get_users.rs | 97 +++
.../src/responses/users/login_user.rs | 75 +++
.../src/responses/users/logout_user.rs} | 2 +-
.../binary_protocol/src/responses/users/mod.rs | 42 +-
.../src/responses/users/update_permissions.rs} | 2 +-
.../src/responses/users/update_user.rs} | 2 +-
.../src/responses/users/user_response.rs | 132 ++++
core/cli/Cargo.toml | 2 +-
core/cli/src/commands/binary_system/stats.rs | 23 +
core/common/Cargo.toml | 2 +-
core/common/src/traits/binary_mapper.rs | 38 ++
core/common/src/types/segment.rs | 29 +-
.../src/types/segment_storage/messages_reader.rs | 4 +-
core/common/src/types/stats/mod.rs | 9 +
.../src/harness/handle/connectors_runtime.rs | 16 +-
core/integration/src/harness/handle/mcp.rs | 12 +-
.../tests/cli/system/test_stats_command.rs | 130 +++-
core/integration/tests/connectors/mongodb/mod.rs | 2 +-
core/integration/tests/server/message_cleanup.rs | 7 +
.../concurrent_produce_consume_scenario.rs | 196 ++++++
.../server/scenarios/message_cleanup_scenario.rs | 140 ++++
core/integration/tests/server/scenarios/mod.rs | 1 +
core/sdk/Cargo.toml | 2 +-
core/server/src/binary/mapper.rs | 4 +
core/server/src/bootstrap.rs | 2 +-
core/server/src/shard/mod.rs | 13 +-
core/server/src/shard/system/segments.rs | 12 +-
core/server/src/shard/system/stats.rs | 21 +
.../src/shard/tasks/periodic/sysinfo_printer.rs | 12 +-
examples/go/getting-started/consumer/main.go | 7 +-
examples/go/getting-started/producer/main.go | 7 +-
.../Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj | 3 +-
foreign/go/client/tcp/tcp_core.go | 84 ++-
foreign/go/contracts/client.go | 4 +-
foreign/go/tests/tls_test.go | 15 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 6 +
.../async/tcp/AsyncIggyTcpClientBuilder.java | 17 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 26 +-
.../iggy/client/async/tcp/SystemTcpClient.java | 2 +-
.../iggy/client/blocking/http/IggyHttpClient.java | 6 +
.../blocking/http/IggyHttpClientBuilder.java | 14 +-
.../client/blocking/http/MessagesHttpClient.java | 4 +-
.../client/blocking/tcp/IggyTcpClientBuilder.java | 15 +-
.../client/async/AsyncClientIntegrationTest.java | 732 +++++---------------
.../iggy/client/async/AsyncConsumerGroupsTest.java | 343 +++-------
.../iggy/client/async/AsyncPollMessageTest.java | 333 ---------
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 79 +++
.../iggy/client/async/tcp/UsersTcpClientTest.java | 239 -------
.../blocking/ConsumerGroupsClientBaseTest.java | 2 +-
.../client/blocking/MessagesClientBaseTest.java | 82 +++
.../iggy/client/blocking/SystemClientBaseTest.java | 21 +
.../iggy/client/blocking/UsersClientBaseTest.java | 64 +-
.../blocking/tcp/IggyTcpClientBuilderTest.java | 68 ++
foreign/python/Cargo.toml | 2 +-
scripts/run-bdd-tests.sh | 30 +-
192 files changed, 14318 insertions(+), 2389 deletions(-)
create mode 100644 bdd/docker-compose.coverage.yml
create mode 100644 core/binary_protocol/src/codec.rs
create mode 100644 core/binary_protocol/src/codes.rs
create mode 100644 core/binary_protocol/src/consensus/command.rs
create mode 100644 core/binary_protocol/src/consensus/error.rs
copy core/{common/src/types => binary_protocol/src}/consensus/header.rs (57%)
create mode 100644 core/binary_protocol/src/consensus/message.rs
create mode 100644 core/binary_protocol/src/consensus/mod.rs
create mode 100644 core/binary_protocol/src/consensus/operation.rs
create mode 100644 core/binary_protocol/src/error.rs
copy bdd/go/tests/suite_test.go => core/binary_protocol/src/frame.rs (56%)
create mode 100644 core/binary_protocol/src/message_layout.rs
create mode 100644 core/binary_protocol/src/message_view.rs
create mode 100644 core/binary_protocol/src/primitives/consumer.rs
create mode 100644 core/binary_protocol/src/primitives/identifier.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/primitives}/mod.rs (82%)
create mode 100644 core/binary_protocol/src/primitives/partitioning.rs
create mode 100644 core/binary_protocol/src/primitives/permissions.rs
create mode 100644 core/binary_protocol/src/primitives/polling_strategy.rs
create mode 100644 core/binary_protocol/src/requests/consumer_groups/create_consumer_group.rs
create mode 100644 core/binary_protocol/src/requests/consumer_groups/delete_consumer_group.rs
create mode 100644 core/binary_protocol/src/requests/consumer_groups/get_consumer_group.rs
create mode 100644 core/binary_protocol/src/requests/consumer_groups/get_consumer_groups.rs
create mode 100644 core/binary_protocol/src/requests/consumer_groups/join_consumer_group.rs
create mode 100644 core/binary_protocol/src/requests/consumer_groups/leave_consumer_group.rs
copy core/{bench/dashboard/frontend/src/components/layout/logo.rs => binary_protocol/src/requests/consumer_groups/mod.rs} (63%)
create mode 100644 core/binary_protocol/src/requests/consumer_offsets/delete_consumer_offset.rs
create mode 100644 core/binary_protocol/src/requests/consumer_offsets/get_consumer_offset.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/requests/consumer_offsets}/mod.rs (75%)
create mode 100644 core/binary_protocol/src/requests/consumer_offsets/store_consumer_offset.rs
create mode 100644 core/binary_protocol/src/requests/messages/flush_unsaved_buffer.rs
copy core/{common/src/commands => binary_protocol/src/requests}/messages/mod.rs (80%)
create mode 100644 core/binary_protocol/src/requests/messages/poll_messages.rs
create mode 100644 core/binary_protocol/src/requests/messages/send_messages.rs
copy core/{bench/dashboard/frontend/src/components/tooltips => binary_protocol/src/requests}/mod.rs (79%)
create mode 100644 core/binary_protocol/src/requests/partitions/create_partitions.rs
create mode 100644 core/binary_protocol/src/requests/partitions/delete_partitions.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/requests/partitions}/mod.rs (83%)
create mode 100644 core/binary_protocol/src/requests/personal_access_tokens/create_personal_access_token.rs
create mode 100644 core/binary_protocol/src/requests/personal_access_tokens/delete_personal_access_token.rs
create mode 100644 core/binary_protocol/src/requests/personal_access_tokens/get_personal_access_tokens.rs
create mode 100644 core/binary_protocol/src/requests/personal_access_tokens/login_with_personal_access_token.rs
copy core/{bench/dashboard/server/src/github => binary_protocol/src/requests/personal_access_tokens}/mod.rs (64%)
create mode 100644 core/binary_protocol/src/requests/segments/delete_segments.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/requests/segments}/mod.rs (91%)
create mode 100644 core/binary_protocol/src/requests/streams/create_stream.rs
create mode 100644 core/binary_protocol/src/requests/streams/delete_stream.rs
create mode 100644 core/binary_protocol/src/requests/streams/get_stream.rs
copy core/{common/src/sharding/local_idx.rs => binary_protocol/src/requests/streams/get_streams.rs} (51%)
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/requests/streams}/mod.rs (67%)
create mode 100644 core/binary_protocol/src/requests/streams/purge_stream.rs
create mode 100644 core/binary_protocol/src/requests/streams/update_stream.rs
create mode 100644 core/binary_protocol/src/requests/system/get_client.rs
copy core/{common/src/sharding/local_idx.rs => binary_protocol/src/requests/system/get_clients.rs} (51%)
create mode 100644 core/binary_protocol/src/requests/system/get_cluster_metadata.rs
copy core/{common/src/types/consumer/consumer_offsets.rs => binary_protocol/src/requests/system/get_me.rs} (52%)
copy foreign/csharp/Iggy_SDK/JsonConverters/TimeSpanConverter.cs => core/binary_protocol/src/requests/system/get_snapshot.rs (54%)
copy core/{common/src/types/consumer/consumer_offsets.rs => binary_protocol/src/requests/system/get_stats.rs} (51%)
copy core/{bench/dashboard/server/src/github => binary_protocol/src/requests/system}/mod.rs (66%)
copy core/{common/src/types/consumer/consumer_offsets.rs => binary_protocol/src/requests/system/ping.rs} (52%)
create mode 100644 core/binary_protocol/src/requests/topics/create_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/delete_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/get_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/get_topics.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/requests/topics}/mod.rs (68%)
create mode 100644 core/binary_protocol/src/requests/topics/purge_topic.rs
create mode 100644 core/binary_protocol/src/requests/topics/update_topic.rs
create mode 100644 core/binary_protocol/src/requests/users/change_password.rs
create mode 100644 core/binary_protocol/src/requests/users/create_user.rs
create mode 100644 core/binary_protocol/src/requests/users/delete_user.rs
create mode 100644 core/binary_protocol/src/requests/users/get_user.rs
copy core/{common/src/types/consumer/consumer_offsets.rs => binary_protocol/src/requests/users/get_users.rs} (51%)
create mode 100644 core/binary_protocol/src/requests/users/login_user.rs
copy core/{common/src/sharding/local_idx.rs => binary_protocol/src/requests/users/logout_user.rs} (51%)
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/requests/users}/mod.rs (58%)
create mode 100644 core/binary_protocol/src/requests/users/update_permissions.rs
create mode 100644 core/binary_protocol/src/requests/users/update_user.rs
create mode 100644 core/binary_protocol/src/responses/clients/client_response.rs
create mode 100644 core/binary_protocol/src/responses/clients/get_client.rs
create mode 100644 core/binary_protocol/src/responses/clients/get_clients.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/responses/clients}/mod.rs (78%)
create mode 100644 core/binary_protocol/src/responses/consumer_groups/consumer_group_response.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/consumer_groups/create_consumer_group.rs} (88%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/consumer_groups/delete_consumer_group.rs} (88%)
create mode 100644 core/binary_protocol/src/responses/consumer_groups/get_consumer_group.rs
create mode 100644 core/binary_protocol/src/responses/consumer_groups/get_consumer_groups.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/consumer_groups/join_consumer_group.rs} (88%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/consumer_groups/leave_consumer_group.rs} (88%)
copy bdd/go/tests/tcp_test/session_feature_logout.go => core/binary_protocol/src/responses/consumer_groups/mod.rs (55%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/consumer_offsets/delete_consumer_offset.rs} (88%)
create mode 100644 core/binary_protocol/src/responses/consumer_offsets/get_consumer_offset.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/responses/consumer_offsets}/mod.rs (73%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/consumer_offsets/store_consumer_offset.rs} (88%)
copy core/{common/src/commands => binary_protocol/src/responses}/messages/mod.rs (91%)
create mode 100644 core/binary_protocol/src/responses/messages/poll_messages.rs
copy core/{common/src/sharding/shard_id.rs => binary_protocol/src/responses/mod.rs} (55%)
create mode 100644 core/binary_protocol/src/responses/personal_access_tokens/create_personal_access_token.rs
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/personal_access_tokens/delete_personal_access_token.rs} (92%)
create mode 100644 core/binary_protocol/src/responses/personal_access_tokens/get_personal_access_tokens.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/personal_access_tokens/login_with_personal_access_token.rs} (89%)
copy core/{common/src/sharding => binary_protocol/src/responses/personal_access_tokens}/mod.rs (61%)
copy core/{bench/dashboard/frontend/src/components/selectors/mod.rs => binary_protocol/src/responses/streams/create_stream.rs} (74%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/streams/delete_stream.rs} (89%)
create mode 100644 core/binary_protocol/src/responses/streams/get_stream.rs
create mode 100644 core/binary_protocol/src/responses/streams/get_streams.rs
copy core/{bench/dashboard/server/src/github => binary_protocol/src/responses/streams}/mod.rs (62%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/streams/purge_stream.rs} (89%)
create mode 100644 core/binary_protocol/src/responses/streams/stream_response.rs
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/streams/update_stream.rs} (89%)
create mode 100644 core/binary_protocol/src/responses/system/get_stats.rs
copy core/{bench/dashboard/frontend/src/hooks => binary_protocol/src/responses/system}/mod.rs (86%)
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/system/ping.rs} (94%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/topics/create_topic.rs} (89%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/topics/delete_topic.rs} (89%)
create mode 100644 core/binary_protocol/src/responses/topics/get_topic.rs
create mode 100644 core/binary_protocol/src/responses/topics/get_topics.rs
copy core/{bench/dashboard/server/src/github => binary_protocol/src/responses/topics}/mod.rs (66%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/topics/purge_topic.rs} (90%)
copy core/{bench/dashboard/frontend/src/state/mod.rs => binary_protocol/src/responses/topics/update_topic.rs} (89%)
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/users/change_password.rs} (93%)
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/users/create_user.rs} (93%)
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/users/delete_user.rs} (93%)
create mode 100644 core/binary_protocol/src/responses/users/get_user.rs
create mode 100644 core/binary_protocol/src/responses/users/get_users.rs
create mode 100644 core/binary_protocol/src/responses/users/login_user.rs
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/users/logout_user.rs} (93%)
copy foreign/csharp/Iggy_SDK/Contracts/ConsumerGroupInfo.cs => core/binary_protocol/src/responses/users/mod.rs (56%)
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/users/update_permissions.rs} (93%)
copy core/{common/src/types/client/mod.rs => binary_protocol/src/responses/users/update_user.rs} (93%)
create mode 100644 core/binary_protocol/src/responses/users/user_response.rs
create mode 100644 core/integration/tests/server/scenarios/concurrent_produce_consume_scenario.rs
delete mode 100644 foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/AsyncPollMessageTest.java
delete mode 100644 foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/UsersTcpClientTest.java