This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch kafka_gateway_group
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 9221034d7 Merge remote-tracking branch 'origin/master' into
kafka_gateway_group
add f46a5733e address reivew
No new revisions were added by this update.
Summary of changes:
gateways/kafka/docs/CONSUMER_GROUPS.md | 4 +
gateways/kafka/src/group/mod.rs | 53 +++++++--
gateways/kafka/src/group/state.rs | 30 ++++++
gateways/kafka/src/protocol/handlers/sync_group.rs | 5 +-
gateways/kafka/tests/consumer_group_tests.rs | 118 ++++++++++++++++++++-
5 files changed, 201 insertions(+), 9 deletions(-)
