kafkaサーバのバージョン確認方法のソースを表示

== 概要 ==
kafka クライアントからサーバのバージョンを調べる方法。

コンシューマーではなくクライアントにメソッドがある。
コンシューマーの init で config に格納されるので consumer.config['api_version'] で確認できる。

== kafka-python での例 ==

<pre>
$ python
>>> import kafka
>>> consumer = kafka.KafkaConsumer()
>>> consumer.config['api_version']
(0, 10, 0)
</pre>

または、

<pre>
$ 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)
</pre>

== 参考・引用 ==
http://kafka-python.readthedocs.io/en/1.4.2/apidoc/KafkaClient.html?highlight=guess#kafka.client.KafkaClient.check_version


[[Category:Apache kafka]]