This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch fix_consumer_group_offset_commit
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b8a0dcbdd fix(server): fix store_consumer_offset for consumer groups
add ac05b6965 update version
add 4efc919d7 add a test
add 498f90310 replace composite key with just consumer group id
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 6 +-
Cargo.toml | 6 +-
core/binary_protocol/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/integration/tests/server/cg.rs | 4 +-
core/integration/tests/server/mod.rs | 10 +-
...umer_group_auto_commit_reconnection_scenario.rs | 201 +++++++++++++++++++++
core/integration/tests/server/scenarios/mod.rs | 1 +
core/sdk/Cargo.toml | 2 +-
core/server/src/bootstrap.rs | 5 +-
core/server/src/shard/system/consumer_offsets.rs | 23 +--
core/server/src/slab/streams.rs | 14 +-
.../src/streaming/partitions/consumer_offset.rs | 12 +-
core/server/src/streaming/partitions/helpers.rs | 50 +++--
core/server/src/streaming/partitions/partition.rs | 10 +-
core/server/src/streaming/partitions/storage.rs | 38 +---
core/server/src/streaming/streams/helpers.rs | 6 +-
foreign/python/Cargo.toml | 2 +-
18 files changed, 280 insertions(+), 114 deletions(-)
create mode 100644
core/integration/tests/server/scenarios/consumer_group_auto_commit_reconnection_scenario.rs
