Fix `api_version=auto` (discover Kafka version)

StephenSorriaux / ansible-kafka-admin

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this library. It does not use the Kafka scripts and does not require ssh connection to the remote broker.

Apache License 2.0

150 stars 46 forks source link

Fix `api_version=auto` (discover Kafka version) #175

Open StephenSorriaux opened 2 weeks ago

StephenSorriaux commented 2 weeks ago

Current auto setting for api_version is supposed to discover the Kafka server version.

Unfortunately it only supports for Kafka 0.10.X, and will not be helpful for the 1.X, 2.X or even 3.X versions we support.

We probably need to re-implement the function ourselves and had more test_cases.