| kafka/tools/assigner/actions/balancemodules/rackaware.py | 118 | A 50 mins |
|
| kafka/tools/assigner/actions/balancemodules/rate.py | 10 | A 0 mins |
|
| kafka/tools/assigner/actions/balancemodules/size.py | 72 | C 1 day |
|
| kafka/tools/assigner/actions/clone.py | 30 | A 2 hrs |
|
| kafka/tools/assigner/actions/demote.py | 30 | A 1 hr |
|
| kafka/tools/assigner/actions/elect.py | 4 | A 0 mins |
|
| kafka/tools/assigner/actions/remove.py | 46 | B 4 hrs |
|
| kafka/tools/assigner/actions/reorder.py | 25 | A 2 hrs |
|
| kafka/tools/assigner/actions/setrf.py | 34 | A 1 hr |
|
| kafka/tools/assigner/actions/trim.py | 26 | A 25 mins |
|
| kafka/tools/assigner/arguments.py | 40 | A 0 mins |
|
| kafka/tools/assigner/batcher.py | 6 | A 0 mins |
|
| kafka/tools/assigner/models/__init__.py | 0 | A 0 mins |
|
| kafka/tools/assigner/models/reassignment.py | 71 | A 45 mins |
|
| kafka/tools/assigner/models/replica_election.py | 27 | A 45 mins |
|
| kafka/tools/assigner/plugins/__init__.py | 23 | A 0 mins |
|
| kafka/tools/assigner/sizers/__init__.py | 12 | A 0 mins |
|
| kafka/tools/assigner/sizers/jmx.py | 56 | A 0 mins |
|
| kafka/tools/assigner/sizers/prometheus.py | 106 | A 35 mins |
|
| kafka/tools/assigner/sizers/ssh.py | 36 | A 0 mins |
|
| kafka/tools/client.py | 666 | F 3 days |
|
| kafka/tools/configuration.py | 199 | B 4 hrs |
|
| kafka/tools/exceptions.py | 40 | A 0 mins |
|
| kafka/tools/models/__init__.py | 8 | A 0 mins |
|
| kafka/tools/models/broker.py | 184 | A 3 hrs |
|
| kafka/tools/models/cluster.py | 131 | A 1 hr |
|
| kafka/tools/models/group.py | 51 | A 1 hr |
|
| kafka/tools/models/partition.py | 91 | A 0 mins |
|
| kafka/tools/models/topic.py | 69 | B 4 hrs |
|
| kafka/tools/modules.py | 32 | A 0 mins |
|
| kafka/tools/protocol/__init__.py | 0 | A 0 mins |
|
| kafka/tools/protocol/__main__.py | 64 | A 35 mins |
|
| kafka/tools/protocol/arguments.py | 8 | A 0 mins |
|
| kafka/tools/protocol/errors.py | 147 | A 1 hr |
|
| kafka/tools/protocol/help.py | 16 | A 0 mins |
|
| kafka/tools/protocol/requests/__init__.py | 118 | C 1 day |
|
| kafka/tools/protocol/requests/alter_configs_v0.py | 23 | A 1 hr |
|
| kafka/tools/protocol/requests/alter_replica_log_dirs_v0.py | 21 | A 40 mins |
|
| kafka/tools/protocol/requests/api_versions_v0.py | 17 | B 6 hrs |
|
| kafka/tools/protocol/requests/api_versions_v1.py | 5 | A 0 mins |
|
| kafka/tools/protocol/requests/controlled_shutdown_v0.py | 11 | A 1 hr |
|
| kafka/tools/protocol/requests/controlled_shutdown_v1.py | 5 | A 0 mins |
|
| kafka/tools/protocol/requests/create_acls_v0.py | 20 | B 5 hrs |
|
| kafka/tools/protocol/requests/create_partitions_v0.py | 23 | A 0 mins |
|
| kafka/tools/protocol/requests/create_topics_v0.py | 80 | C 1 day |
|
| kafka/tools/protocol/requests/create_topics_v1.py | 61 | C 1 day |
|
| kafka/tools/protocol/requests/create_topics_v2.py | 5 | A 0 mins |
|
| kafka/tools/protocol/requests/delete_acls_v0.py | 20 | B 5 hrs |
|
| kafka/tools/protocol/requests/delete_records_v0.py | 22 | A 0 mins |
|
| kafka/tools/protocol/requests/delete_topics_v0.py | 20 | A 1 hr |
|