問題タブ [pykafka]
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.
python - 高レイテンシ PyKafka
私たちは、画像を受け取り、関連する情報を送り返すリアルタイム製品を作成しています。スケーラビリティの目的で、Kafka を使用して Kubenertes ノード間のワークロードのバランスをとることにしました。
フロントエンド -> MainWorker -> Kafka (1) -> ワーカー -> Kafka (2) -> MainWorker -> フロントエンド
何らかの理由で、Kafka (1) と kafka (2) の場合、プロデューサーとコンシューマーの間で予期しない 80 ～ 100 ミリ秒が発生します。
レイテンシーは、ローカルにデプロイされたものとクラウドにデプロイされたもので同じです
プロデューサー 1
プロデューサー/コンシューマー 2
遅延を減らすためにいくつかのことを試みましたが、これは遅延に影響を与えていないようです. プロデューサとコンシューマの両方のレイテンシが最小である必要があります。スループットは気にしません。
python - Pykafka クライアントは ssh/tls を無視します
usafe ssl接続で/正しい証明書を持たずにPykafkaクライアントを使用する方法はありますか?
SSL関連のものを構成するには、組み込みのPyKafka SslConfigしか見つかりませんでしたが、SSL検証を無効にするものは何も公開していないようです。