kafkaサーバのバージョン確認方法
提供: Wikiducca
概要
kafka クライアントからサーバのバージョンを調べる方法。
コンシューマーではなくクライアントにメソッドがある。 コンシューマーの init で config に格納されるので consumer.config['api_version'] で確認できる。
kafka-python での例
$ python >>> import kafka >>> consumer = kafka.KafkaConsumer() >>> consumer.config['api_version'] (0, 10, 0)
または、
$ python >>> import kafka >>> consumer = kafka.KafkaConsumer(bootstrap_servers=['kafka-server01:9092', 'kafka-server02:9092', 'kafka-server03:9092'], ... group_id='kafka-test') >>> print(consumer.config['api_version']) (0, 10, 0)