This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch stats-fix
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a7e2a2085 fix(server): fix stream stats corruption on topic purge
add 223e8ba15 feat(server): cooperative partition reassignment for
consumer groups (#2734)
add 1b171164e feat(java): Add test for AsyncIggyTcpClientBuilder (#2726)
add 3cb0d6e53 Merge branch 'master' into stats-fix
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 2 +-
DEPENDENCIES.md | 2 +-
.../tests/connectors/postgres/postgres_source.rs | 23 +-
core/integration/tests/data_integrity/mod.rs | 1 +
.../verify_consumer_group_partition_assignment.rs | 3269 ++++++++++++++++++++
core/server/Cargo.toml | 2 +-
core/server/config.toml | 7 +
core/server/src/bootstrap.rs | 1 +
core/server/src/configs/defaults.rs | 25 +-
core/server/src/configs/displays.rs | 17 +-
core/server/src/configs/server.rs | 12 +
core/server/src/metadata/absorb.rs | 83 +-
core/server/src/metadata/consumer_group.rs | 262 +-
core/server/src/metadata/consumer_group_member.rs | 19 +
core/server/src/metadata/ops.rs | 16 +-
core/server/src/metadata/partition.rs | 4 +
core/server/src/metadata/reader.rs | 213 +-
core/server/src/metadata/writer.rs | 37 +-
core/server/src/shard/handlers.rs | 26 +
core/server/src/shard/mod.rs | 4 +
core/server/src/shard/system/consumer_groups.rs | 15 +-
core/server/src/shard/system/consumer_offsets.rs | 71 +-
core/server/src/shard/system/messages.rs | 26 +-
core/server/src/shard/system/partitions.rs | 1 +
core/server/src/shard/system/utils.rs | 55 +-
core/server/src/shard/tasks/periodic/mod.rs | 2 +
.../src/shard/tasks/periodic/revocation_timeout.rs | 106 +
core/server/src/shard/transmission/frame.rs | 1 +
core/server/src/shard/transmission/message.rs | 9 +
.../ConsumerGroupTests.cs | 5 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 330 +-
31 files changed, 4521 insertions(+), 125 deletions(-)
create mode 100644
core/integration/tests/data_integrity/verify_consumer_group_partition_assignment.rs
create mode 100644 core/server/src/shard/tasks/periodic/revocation_timeout.rs
