問題タブ [confluent-kafka-python]

質問する

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.

114 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
2 に答える
720 参照

python - python-kafka から confluent kafka への変換 - SASL_SSL、OAUTHBEARER、およびトークンとのパリティを作成する方法

私は動作し、コードであるPythonカフカを持っています:

私のコンフルエントなpythonは以下で、このエラーが発生します

では、コンフルエントなカフカを機能させるにはどうすればよいですか? OAUTHBEARER と SASL_SSL を使用する oauthbearer_token_refresh_cb に問題があるようです。

本質的に、私はjwtトークンで認証します

0 投票する
0 に答える
1101 参照

python-3.x - AWS MSK のアドバタイズされたリスナーの設定

MSK クラスターの Advertized.listeners 構成を設定しようとしています。ただし、次のエラーが返されます。

要件が満たされませんでした: inter.broker.listener.name は、advertized.listeners で定義されたリスナー名でなければなりません

このエラーの意味がわかりません。探してみましたが、何も出てきません。VPC 関連のすべての設定が完了しました。クラスターからトピック名とその他の構成を読み取ることができます。

Python の confluent_kafka モジュールの管理クライアントを使用しています。

コードは次のとおりです。

0 投票する
0 に答える
506 参照

amazon-web-services - Kafka: Understanding Broker failure

I have a Kafka cluster with:

  • 2 brokers b-1 and b-2.
  • 2 topics with both: PartitionCount:1 ReplicationFactor:2 min.insync.replicas=1

Here is what happened:

Within the code, I got this error when my producer performed a poll around that time:

Broker b-2 logs have this:

My understanding here is that (1) b-2 went down i.e. unable to connect to Zookeeper (2) Messages were produced to b-1 successfully during this time. (3) b-1 was also trying to forward messages to b-2during this downtime due to the replication factor set to 2 (4) All these forwarded messages (ProduceRequests) got timed-out after 600s

My question:

  1. Is my understanding correct and how I can prevent this from happening again?
  2. If I had 3 brokers here, would b-1 have tried to connect to b-3 right away rather than waiting for b-2? Is that a good workaround? (Assuming topic replication factor = 2 everywhere)

12345678910