「kafkaサーバのバージョン確認方法」の版間の差分
(ページの作成:「== 概要 == kafka クライアントからサーバのバージョンを調べる方法。 コンシューマーではなくクライアントにメソッドがある...」) |
The Pioneer (ノート | 投稿記録) (大松「ブロックされないから荒らしやすいンゴねえ」) |
||
| 行1: | 行1: | ||
| − | == 概要 == | + | <nowiki>Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。== 概要 == |
kafka クライアントからサーバのバージョンを調べる方法。 | kafka クライアントからサーバのバージョンを調べる方法。 | ||
2019年1月1日 (火) 13:08時点における版
Wikiduccaは終了しました。今後はゴールドペディアをご利用ください。== 概要 == 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]]
