0

を使用する（マスターブランチ）pythonバインディングで実行kafka_2.11-0.10.1.1します。私のマシンは ubuntu-16.04 x86_64 を実行しています。ポートで実行します。次のように合流プロデューサーの例を実行します。confluent-kafka-0.9.2librdkafka-0.9.2zookeeper-3.4.8-12181

$ cd confluent-kafka-python/examples
$ python producer.py localhost:9095 confluent-01
first message
2nd msg

そして消費者：

$ python consumer.py localhost:9095 confluentgroup confluent-01

ファイアウォールを実行していない私のマシンでは、すべてがローカルで実行されます。

備考:

  • Zookeeper でトピックが正常に作成されました
  • ブローカーはプロデューサー メッセージを正常に受信します。
  • conf に続く消費者セット{'bootstrap.servers': broker, 'group.id': group, 'session.timeout.ms': 6000, 'default.topic.config': {'auto.offset.reset': 'smallest'}, 'api.version.request': True }
  • 私がプロデューサー側に着くまで、最初producer/consumerはしばらくの間うまくいきました。Receive failed: Disconnected抜粋:
$ python producer.py  localhost:9095 confluent-02
asd
% Message delivered to confluent-02 [0]
1234123
890890
% Message delivered to confluent-02 [0]
%3|1485791262.420|FAIL|rdkafka#producer-1| [thrd:obscura.ax.example.com:9095/3]: obscura.ax.example.com:9095/3: Receive failed: Disconnected

問題: しばらくすると消費者側で何も得られません

質問:

  1. 私は何を間違っていますか？
  2. プロデューサ メッセージがブローカ側で受信されたことを確認するにはどうすればよいですか? プロデューサ メッセージは、ブローカ側で適切に受信されます。
  3. コンシューマー側をデバッグするにはどうすればよいですか? 'debug': "cgrp, topic, fetch"コンシューマーconf に追加しました。ログはどこで読めますか?
4

2 に答える 2

1

2 つの提案があります。

1) オプション --from-beginning をコンシューマー コマンドに追加してみてください

2) ブローカーのデフォルトのポートは 9092 であるため、使用する正しいポートを確認してください

お役に立てれば。

于 2017-01-27T23:30:45.633 に答える