| docs/tools/protocol/requests/leave_group_v0.rst | |
|
|
| docs/tools/protocol/requests/list_groups_v0.rst | |
|
|
| docs/tools/protocol/requests/list_offset_v0.rst | |
|
|
| docs/tools/protocol/requests/offset_commit_v0.rst | |
|
|
| docs/tools/protocol/requests/offset_commit_v1.rst | |
|
|
| docs/tools/protocol/requests/offset_commit_v2.rst | |
|
|
| docs/tools/protocol/requests/offset_fetch_v0.rst | |
|
|
| docs/tools/protocol/requests/offset_fetch_v1.rst | |
|
|
| docs/tools/protocol/requests/sasl_handshake_v0.rst | |
|
|
| docs/tools/protocol/requests/stop_replica_v0.rst | |
|
|
| docs/tools/protocol/requests/sync_group_v0.rst | |
|
|
| docs/tools/protocol/requests/topic_metadata_v0.rst | |
|
|
| docs/tools/protocol/requests/topic_metadata_v1.rst | |
|
|
| docs/tools/protocol/requests/update_metadata_v0.rst | |
|
|
| docs/tools/protocol/responses/api_versions_v0.rst | |
|
|
| docs/tools/protocol/responses/controlled_shutdown_v1.rst | |
|
|
| docs/tools/protocol/responses/create_topics_v0.rst | |
|
|
| docs/tools/protocol/responses/delete_topics_v0.rst | |
|
|
| docs/tools/protocol/responses/describe_groups_v0.rst | |
|
|
| docs/tools/protocol/responses/group_coordinator_v0.rst | |
|
|
| docs/tools/protocol/responses/heartbeat_v0.rst | |
|
|
| docs/tools/protocol/responses/join_group_v0.rst | |
|
|
| docs/tools/protocol/responses/leader_and_isr_v0.rst | |
|
|
| docs/tools/protocol/responses/leave_group_v0.rst | |
|
|
| docs/tools/protocol/responses/list_groups_v0.rst | |
|
|
| docs/tools/protocol/responses/list_offset_v0.rst | |
|
|
| docs/tools/protocol/responses/metadata_v0.rst | |
|
|
| docs/tools/protocol/responses/metadata_v1.rst | |
|
|
| docs/tools/protocol/responses/offset_commit_v0.rst | |
|
|
| docs/tools/protocol/responses/offset_commit_v1.rst | |
|
|
| docs/tools/protocol/responses/offset_commit_v2.rst | |
|
|
| docs/tools/protocol/responses/offset_fetch_v0.rst | |
|
|
| docs/tools/protocol/responses/offset_fetch_v1.rst | |
|
|
| docs/tools/protocol/responses/sasl_handshake_v0.rst | |
|
|
| docs/tools/protocol/responses/stop_replica_v0.rst | |
|
|
| docs/tools/protocol/responses/sync_group_v0.rst | |
|
|
| docs/tools/protocol/responses/update_metadata_v0.rst | |
|
|
| docs/tools/protocol/types/bytebuffer.rst | |
|
|
| docs/tools/utilities.rst | |
|
|
| setup.cfg | |
|
|
| tox.ini | |
|
|
| docs/conf.py | 12 |
|
|
| kafka/__init__.py | 5 |
|
|
| kafka/tools/__init__.py | 13 |
|
|
| kafka/tools/assigner/__init__.py | 0 |
|
|
| kafka/tools/assigner/__main__.py | 100 | A 3 hrs |
|
| kafka/tools/assigner/actions/__init__.py | 27 |
|
|
| kafka/tools/assigner/actions/balance.py | 25 |
|
|
| kafka/tools/assigner/actions/balancemodules/__init__.py | 0 |
|
|
| kafka/tools/assigner/actions/balancemodules/count.py | 71 | D 2 days |
|