問題タブ [confluent-cloud]
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.
confluent-platform - セルフマネージド ksqlDB を Confluent Cloud に接続 | マネージド ksql サーバー
これは、自己管理型の ksqlDB / ksql サーバーをコンフルエントなクラウドに接続する方法に関する質問です。
GCP asia south のhttps://confluent.cloud/で実行されているコンフルエントな基本クラスターがあります。
このクラスターでは、自己管理型の ksqlDB を Confluent Cloud Control Center に接続したいと考えています。
これは、コンフルエントなクラウドからコピーしてマネージド ksqldb に配置した構成です。
この自己管理型の ksqldb は、単一マシンの GCP コンピューティング ユニットです。
同じ構成が次のプロパティに存在します。
また、次のコマンドを使用して ksql サーバーを起動しました。
コマンドライン ：
でいくつかのことが指摘されましたksql terminal。
STREAM はターミナルで正常に作成されましたが、クラウドでは使用できません。
コマンド「ストリームを表示」特定のSTREAMを表示できます。
{ストリーム}を印刷します。データがSTREAMにプッシュされている間でも、データは表示されません。
ホスト エントリを設定していません。
コネクタを表示すると、ksql ターミナルで次の例外が生成されます。
ksql> コネクタを表示します。io.confluent.ksql.util.KsqlServerException: org.apache.http.conn.HttpHostConnectException: localhost:8083 に接続します [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1]失敗: 接続が拒否されました (接続が拒否されました) 原因: org.apache.http.conn.HttpHostConnectException: localhost:8083 に接続 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1 ] 失敗しました: 接続が拒否されました (接続が拒否されました) 原因: サーバーに接続できませんでした。原因: サーバーに接続できませんでした。
ksqlDB がコンフルエント クラウドに表示されることを期待していますが、表示できません。
自己管理型の ksql サーバーが機能し、コンフルエントなクラウドに表示されるようにするには、さらにどのような構成が必要かわかりません。
apache-kafka - Pythonですべてのオフセットkafkaを読み取る
Kafka のトピックのすべてのメッセージを読み取ろうとしています。コンフルエントなクラウド サービスを使用しているため、ローカルホストで Kafka を実行しないでください。構成を次のように設定しました'enable.auto.commit': 'True','auto.offset.reset': 'earliest', 'default.topic.config': {'auto.offset.reset': 'smallest'}。ただし、メッセージが表示されないか、プロデューサーから同時にメッセージを送信すると、すべてのオフセットメッセージではなく、そのメッセージのみが表示されます。
Pythonですべてのオフセットメッセージを読むにはどうすればよいですか?