mirror of https://github.com/apache/kafka.git
c5a78b0186
CI / build (push) Waiting to run
Details
According to the current code in AK, the offset reset strategy for share groups was set using the flag `--offset-reset-strategy` in the share_consumer_test.py tests, but that would mean that the admin client call would be sent out by all members in the share group. This PR changes that by introducing `set_group_offset_reset_strategy` method in kafka.py, which runs the kafka-configs.sh script in one of the existing docker containers, thereby changing the config only once. Reviewers: Andrew Schofield <aschofield@confluent.io> |
||
|---|---|---|
| .. | ||
| kafka | ||
| monitor | ||
| performance | ||
| security | ||
| templates | ||
| trogdor | ||
| __init__.py | ||
| connect.py | ||
| console_consumer.py | ||
| console_share_consumer.py | ||
| consumer_property.py | ||
| delegation_tokens.py | ||
| log_compaction_tester.py | ||
| replica_verification_tool.py | ||
| streams.py | ||
| streams_property.py | ||
| transactional_message_copier.py | ||
| verifiable_client.py | ||
| verifiable_consumer.py | ||
| verifiable_producer.py | ||
| verifiable_share_consumer.py | ||
| zookeeper.py | ||