次のコードを介してクラスターpykafkaを接続するために使用する場合:kafka
from pykafka import KafkaClient
client = KafkaClient(hosts="10.0.0.101:9092")
次のように例外が発生しました。
raise Exception('ブローカに接続してメタデータを取得できません。')
例外: ブローカに接続してメタデータをフェッチできません。
しかし、次のようなコマンドラインを使用していたとき:
kafka-console-producer --broker-list 10.0.0.101:9092 --topic userCND
正常に動作しますが、警告メッセージが表示されます。
WARN プロパティのトピックが無効です (kafka.utils.VerifiableProperties)