「kafkaサーバのバージョン確認方法」の版間の差分

提供: Wikiducca
移動: 案内検索
(大松「ブロックされないから荒らしやすいンゴねえ」)
(いたずら対策)
(同じ利用者による、間の1版が非表示)
行1: 行1:
<nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。<nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。<nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。<nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。<nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。<nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。<nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。== 概要 ==
+
== 概要 ==
 
kafka クライアントからサーバのバージョンを調べる方法。
 
kafka クライアントからサーバのバージョンを調べる方法。
  

2019年1月17日 (木) 13:40時点における版

概要

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)

参考・引用

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