| kafka/tools/client.py | 666 | F 3 days |
|
| kafka/tools/configuration.py | 199 | B 4 hrs |
|
| kafka/tools/models/broker.py | 184 | A 3 hrs |
|
| kafka/tools/protocol/errors.py | 147 | A 1 hr |
|
| kafka/tools/models/cluster.py | 131 | A 1 hr |
|
| setup.py | 125 | A 0 mins |
|
| kafka/tools/assigner/actions/balancemodules/rackaware.py | 118 | A 50 mins |
|
| kafka/tools/protocol/requests/__init__.py | 118 | C 1 day |
|
| kafka/tools/assigner/sizers/prometheus.py | 106 | A 35 mins |
|
| kafka/tools/protocol/types/bytebuffer.py | 101 | B 6 hrs |
|
| kafka/tools/assigner/__main__.py | 100 | A 3 hrs |
|
| kafka/tools/models/partition.py | 91 | A 0 mins |
|
| kafka/tools/protocol/requests/create_topics_v0.py | 80 | C 1 day |
|
| kafka/tools/utilities.py | 74 | A 25 mins |
|
| kafka/tools/assigner/actions/balancemodules/size.py | 72 | C 1 day |
|
| kafka/tools/assigner/actions/balancemodules/count.py | 71 | D 2 days |
|
| kafka/tools/assigner/models/reassignment.py | 71 | A 45 mins |
|
| kafka/tools/models/topic.py | 69 | B 4 hrs |
|
| kafka/tools/protocol/requests/offset_commit_v1.py | 68 | C 1 day |
|
| kafka/tools/protocol/responses/__init__.py | 66 | A 2 hrs |
|
| kafka/tools/assigner/actions/balancemodules/even.py | 65 | C 1 day |
|
| kafka/tools/protocol/__main__.py | 64 | A 35 mins |
|
| kafka/tools/protocol/requests/list_offset_v0.py | 61 | D 2 days |
|
| kafka/tools/protocol/requests/create_topics_v1.py | 61 | C 1 day |
|
| kafka/tools/protocol/requests/list_offset_v1.py | 58 | D 2 days |
|
| kafka/tools/protocol/requests/offset_commit_v0.py | 58 | C 1 day |
|
| kafka/tools/assigner/sizers/jmx.py | 56 | A 0 mins |
|
| kafka/tools/protocol/requests/join_group_v0.py | 51 | A 55 mins |
|
| kafka/tools/models/group.py | 51 | A 1 hr |
|
| kafka/tools/assigner/actions/remove.py | 46 | B 4 hrs |
|
| kafka/tools/protocol/requests/offset_commit_v2.py | 45 | A 55 mins |
|
| kafka/tools/protocol/requests/list_offset_v2.py | 44 | A 2 hrs |
|
| kafka/tools/protocol/requests/join_group_v1.py | 41 | B 4 hrs |
|
| kafka/tools/exceptions.py | 40 | A 0 mins |
|
| kafka/tools/assigner/arguments.py | 40 | A 0 mins |
|
| kafka/tools/protocol/requests/offset_fetch_v0.py | 38 | A 1 hr |
|
| kafka/tools/protocol/requests/update_metadata_v4.py | 37 | A 3 hrs |
|
| kafka/tools/assigner/sizers/ssh.py | 36 | A 0 mins |
|
| kafka/tools/protocol/requests/update_metadata_v3.py | 36 | A 3 hrs |
|
| kafka/tools/assigner/actions/setrf.py | 34 | A 1 hr |
|
| kafka/tools/protocol/requests/update_metadata_v2.py | 34 | C 1 day |
|
| kafka/tools/protocol/requests/update_metadata_v1.py | 34 | C 1 day |
|
| kafka/tools/protocol/requests/sync_group_v0.py | 33 | A 40 mins |
|
| kafka/tools/protocol/responses/metadata_v5.py | 32 | A 0 mins |
|
| kafka/tools/modules.py | 32 | A 0 mins |
|
| kafka/tools/protocol/responses/metadata_v3.py | 31 | B 4 hrs |
|
| kafka/tools/protocol/requests/update_metadata_v0.py | 31 | C 1 day |
|
| kafka/tools/protocol/requests/leader_and_isr_v0.py | 31 | C 1 day |
|
| kafka/tools/protocol/responses/metadata_v2.py | 30 | B 4 hrs |
|
| kafka/tools/protocol/responses/metadata_v0.py | 30 | A 0 mins |
|