Python-Kafka：スクリプトモードではなく対話モードで実行されているプログラム

Question

Machine_1のpythonスクリプトを使用して、Machine_2のKafkaトピックにいくつかのメッセージを送信しようとしています。 Machine_2とMachine_1は同じネットワークにあり、どちらもAzureのVMです。

コード：sampl.py

from kafka import KafkaProducer 
Producer = KafkaProducer(bootstrap_servers=['Machine_2:9092']) 
Producer.send('test', 'hello') 

私は

のpython sampl.py

として上記のコードを実行した場合Machine_2に達する何もメッセージはありません。私が行う場合ただし、：

のpython -i sampl.py

をその後のメッセージはMachine_2に達します。私はkafka-console-consumer.shを使って同じものをチェックした。私はyum updateをMachine_1に入れました。ここにいくつかの図書館がないかもしれないと思っています。しかし、運はまだありません。

ありがとうございました。

Answer 1

kafka-python maintainerはこちら。 Producer.send('test', b'hello')は非同期であり、即時配信を提供しません。あなたが見ている可能性があるのは、プロデューサがネットワーク送信を完了する機会を得る前に、Pythonインタープリタがシャットダウンしていることです。

スクリプトを終了する前にメッセージが送信されるまで待つ場合は、.get（timeout = ...）を使用する必要があります。だから、試してみてください。

Producer.send('test', b'hello').get(timeout=1000)

または交互に、あなたはすべての未送信メッセージのために同じことを行うために）（フラッシュを呼び出すことができます：あなたはカフカ-Pythonとカフカブローカーの

Producer.flush(timeout=1000)