Index

A

AssignerException

B

BalanceException

C

check_java_home() (in module kafka.tools.utilities) check_partition_swappable() (in module kafka.tools.assigner.actions.balancemodules.rackaware) ClientError ClusterConsistencyException

ConfigurationError ConfigurationException ConnectionError CSVAction (class in kafka.tools.assigner.arguments)

D

difference_in_size_to_last_partition() (in module kafka.tools.assigner.actions.balancemodules.rackaware)

F

find_path_containing() (in module kafka.tools.utilities)

G

get_tools_path() (in module kafka.tools.utilities)

GroupError

I

is_exec_file() (in module kafka.tools.utilities)

J

json_loads() (in module kafka.tools.utilities)

K

kafka.tools.assigner.actions.balance (module) kafka.tools.assigner.actions.balancemodules.count (module) kafka.tools.assigner.actions.balancemodules.even (module) kafka.tools.assigner.actions.balancemodules.leader (module) kafka.tools.assigner.actions.balancemodules.rackaware (module) kafka.tools.assigner.actions.balancemodules.size (module) kafka.tools.assigner.actions.clone (module) kafka.tools.assigner.actions.elect (module) kafka.tools.assigner.actions.remove (module) kafka.tools.assigner.actions.reorder (module) kafka.tools.assigner.actions.setrf (module) kafka.tools.assigner.actions.trim (module) kafka.tools.assigner.arguments (module) kafka.tools.assigner.batcher (module) kafka.tools.assigner.models.reassignment (module) kafka.tools.assigner.models.replica_election (module) kafka.tools.assigner.sizers.ssh (module) kafka.tools.exceptions (module) kafka.tools.models.broker (module) kafka.tools.models.partition (module) kafka.tools.models.topic (module) kafka.tools.modules (module) kafka.tools.protocol.arguments (module) kafka.tools.protocol.errors (module) kafka.tools.protocol.help (module) kafka.tools.protocol.requests.api_versions_v0 (module) kafka.tools.protocol.requests.controlled_shutdown_v1 (module) kafka.tools.protocol.requests.create_topics_v0 (module) kafka.tools.protocol.requests.delete_topics_v0 (module) kafka.tools.protocol.requests.describe_groups_v0 (module) kafka.tools.protocol.requests.group_coordinator_v0 (module) kafka.tools.protocol.requests.heartbeat_v0 (module) kafka.tools.protocol.requests.join_group_v0 (module) kafka.tools.protocol.requests.leader_and_isr_v0 (module) kafka.tools.protocol.requests.leave_group_v0 (module) kafka.tools.protocol.requests.list_groups_v0 (module) kafka.tools.protocol.requests.list_offset_v0 (module)

kafka.tools.protocol.requests.offset_commit_v0 (module) kafka.tools.protocol.requests.offset_commit_v1 (module) kafka.tools.protocol.requests.offset_commit_v2 (module) kafka.tools.protocol.requests.offset_fetch_v0 (module) kafka.tools.protocol.requests.offset_fetch_v1 (module) kafka.tools.protocol.requests.sasl_handshake_v0 (module) kafka.tools.protocol.requests.stop_replica_v0 (module) kafka.tools.protocol.requests.sync_group_v0 (module) kafka.tools.protocol.requests.topic_metadata_v0 (module) kafka.tools.protocol.requests.topic_metadata_v1 (module) kafka.tools.protocol.requests.update_metadata_v0 (module) kafka.tools.protocol.responses.api_versions_v0 (module) kafka.tools.protocol.responses.controlled_shutdown_v1 (module) kafka.tools.protocol.responses.create_topics_v0 (module) kafka.tools.protocol.responses.delete_topics_v0 (module) kafka.tools.protocol.responses.describe_groups_v0 (module) kafka.tools.protocol.responses.group_coordinator_v0 (module) kafka.tools.protocol.responses.heartbeat_v0 (module) kafka.tools.protocol.responses.join_group_v0 (module) kafka.tools.protocol.responses.leader_and_isr_v0 (module) kafka.tools.protocol.responses.leave_group_v0 (module) kafka.tools.protocol.responses.list_groups_v0 (module) kafka.tools.protocol.responses.list_offset_v0 (module) kafka.tools.protocol.responses.metadata_v0 (module) kafka.tools.protocol.responses.metadata_v1 (module) kafka.tools.protocol.responses.offset_commit_v0 (module) kafka.tools.protocol.responses.offset_commit_v1 (module) kafka.tools.protocol.responses.offset_commit_v2 (module) kafka.tools.protocol.responses.offset_fetch_v0 (module) kafka.tools.protocol.responses.offset_fetch_v1 (module) kafka.tools.protocol.responses.sasl_handshake_v0 (module) kafka.tools.protocol.responses.stop_replica_v0 (module) kafka.tools.protocol.responses.sync_group_v0 (module) kafka.tools.protocol.responses.update_metadata_v0 (module) kafka.tools.protocol.types.bytebuffer (module) kafka.tools.utilities (module) KafkaToolsException

N

NotEnoughReplicasException

O

OffsetError

P

ProgrammingException

R

racks_for_replica_list() (in module kafka.tools.assigner.actions.balancemodules.rackaware)

ReassignmentFailedException ReplicaNotFoundException

S

synchronized() (in module kafka.tools.utilities)

T

TopicError

U

UnknownBrokerException

Z

ZookeeperException