kafka-tools
kafka-tools copied to clipboard
A collection of tools for working with Apache Kafka.
https://github.com/linkedin/kafka-tools/blob/0d98bbefc1105851b7b7203de4f6c68d9c097730/kafka/tools/assigner/actions/reorder.py#L51 partition.replicas[0] throws IndexError. Should be checked for null or empty before the index is referred
In the latest version of kafka-tools, when kafka cluster is used for containerization, kafka-tools cannot connect to the instance on the container. It can be seen that the IP of...
Hey, I am using `poetry` tool to manage my dependencies. My package uses `aiokafka` for consumer/producer management with `kafka-python` as its dependency. When istalling both `kafka-tools` and `aiokafka`, `kafka-tools` overwrites...
The `even` mode in `balance` is the following: ``` even - This is a specialized type for clusters which have topics that have a number of partitions that are a...
While in general splitting the partitions to multiple batch will reduce the chance that broker get overwhelmed by rebalance traffic, it's still possible rebalance traffic will pose pressure to brokers...
Now kafka-protocol uses commands with higher versions too
kafka-protocol uses only version zero for the different commands. Even on entering **help** it shows only the v0 commands. Although kafka-protocols has got support for other api_verions too. However only...
This fixes the issue with help command. Now help will show the desired help string for valid commands