「kafkaサーバのバージョン確認方法」の版間の差分
提供: Wikiducca
(大松「ブロックされないから荒らしやすいンゴねえ」) |
(いたずら対策) |
||
(同じ利用者による、間の1版が非表示) | |||
行1: | 行1: | ||
− | + | == 概要 == | |
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)