問題タブ [apache-pulsar]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Apache Beam: Kafka コンシューマーが何度も再起動する
Kafka Topic からレコードを読み取り、それらを Pulsar Topic に書き込む、この非常に単純な Beam Pipeline があります。
私の理解では、これにより、その値をパイプラインにプッシュする正確に 1 つの Kafka コンシューマーが作成されるはずです。何らかの理由で、パイプラインが何度も再起動して、複数の Kafka コンシューマーと複数の Pulsar プロデューサーを作成しているようです。
複数の Kafka コンシューマが作成されていることを示すログからの抜粋を次に示します。
Kafka コンシューマが何度も再起動されるのはなぜですか? これは予想される動作ですか？
python - pulsar-client をインストールできませんでした
ドキュメントに記載されているように、インストールできませんpulsar-client：
pulsar-client の収集エラー: 要件 pulsar-client を満たすバージョンが見つかりませんでした (バージョンから: なし) エラー: pulsar-client に一致するディストリビューションが見つかりませんでした
pulsar-client==2.4.0 を収集中 エラー: 要件 pulsar-client==2.4.0 を満たすバージョンが見つかりませんでした (バージョンから: なし) エラー: pulsar-client==2.4.0 に一致するディストリビューションが見つかりませんでした
私はWindows 10、python 3バージョンを使用しています。
python2バージョンと3バージョンの両方を試しました。