kafka-kit
kafka-kit copied to clipboard
DataDog
Kafka storage rebalancing, automated replication throttle, cluster API and more
In order to prepare kafka-kit for zk-less kafka, we need to implement at least the following methods from [zkhandler](https://pkg.go.dev/github.com/DataDog/kafka-kit/[email protected]/kafkazk#ZKHandler) into [kafkaadmin/client](https://pkg.go.dev/github.com/DataDog/kafka-kit/[email protected]/kafkaadmin#Client). This should query kafka directly rather than zk. *...
When applying a tag filter via curl (behavior with grpc hasn't been reviewed), incorrectly formed tag parameters will not emit an error. This may result in a user unexpected receiving...
As per the README: > Tested with Go 1.10+ (required), Kafka 0.10.x, ZooKeeper 3.4.x. Due to dependency on `spf13/cobra` the requirement of `go` version seems to be higher. ``` $...
Replica placement isn't guaranteed otherwise since we don't call the kafkazk Rebuild method on the map.
Hello, I was looking in the doc, issues and internet, no way to find how to push `kafka.log.partition.size` metric. It's not part of the default of the default metrics https://docs.datadoghq.com/integrations/kafka/....
Using kafka-kit to perform some rebuild operations to expand a broker cluster. Process: - I ran metricsfetcher to generate metrics - I generated new maps for all my topics using...
An endpoint that can dump topic configs, states in a serialized format for reconstruction elsewhere.
Autothrottle should flush cached throttle rates on interval to reconcile out of sync configurations that may have been set externally. One issue with flushing the rates blindly is that calculating...