問題タブ [event-stream-processing]
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.
apache-flink - イベント集計後に AggregateFunction getResult() が呼び出されていない
Kafka ストリームを読み取り、セッションを集約するための Flink ジョブを実装しようとしていますが、何らかの理由で getResult() が呼び出されていません。createAccumulator() と add() が呼び出されたことがわかりました。集約されたメッセージを送信先にシンクできるように、getResult() も呼び出されることを期待しています。
問題は何ですか？私は何かを誤って設定しましたか？あなたの助けに感謝！
wso2 - siddhi を使用したオンデマンド クエリが失敗する
siddhi アプリケーションを実行するために、wso2 ストリーム インテグレーターを使用しています。動作環境はwindows10proです。Siddhi の REST API の使い方を教えてください。
- 管理者としてコマンド プロンプトを開き、\wso2si-1.1.0\bin に移動します。次に、コマンドを実行し
server.bat --runます。 - wso2si-1.1.0\wso2\server\deployment\siddhi-files にある siddhi ファイルをデプロイすると、正しく機能します。
- 新しいコマンド プロンプトを開き、コマンドを実行します
curl -X GET "http://localhost:9090/siddhi-apps" -H "accept: application/json" -u "admin:admin" -k。 - コマンドが成功し、アプリケーションの一覧が表示されます。
- 次に、
ABCas named-window onを定義しFlowApp、コマンドを実行しましたcurl -X POST "https://localhost:9443/query" -H "content-type: application/json" -u "admin:admin" -d "{"appName" : "FlowApp", "query" : "from ABC select *" }" -k - 上記のクエリは失敗し、コマンド プロンプトに「アクセスの問題: /クエリ。理由: 見つかりません」と表示されます。
「/query」が見つからないのはなぜですか?
scala - Confluent Cloud で Snowplow と Kafka を接続する際の問題
Web Tracker、Scala Stream Kafka Collector、Stream Enrich、Druid、および Metabase を使用して、Docker 内で動作するエンド ツー エンドのローカル実装を取得することができました。
Helm を使用して Kubernetes 内で動作するステージング環境を構築する前に、Scala Stream Kafka Collector を Kafka Confluent Cloud アカウントに接続してみました。ただし、SASL 認証で問題が発生しています。この件に関するドキュメントはかなりまばらで、Kafka のドキュメントを示しているだけです。これが私のconfig.hocon構成です-
ただし、コンテナが起動すると、出力の構成が一致しません -
さらに、コンソールに次のエラーが表示されます -
通常のチャネルでヘルプを検索しているときに、このエラーは JAAS 構成がプロデューサーに表示されないことが原因であることが示唆されているため、これは単に私の側の構成の問題であると確信しています。何かが欠けていない限り、構成オプションが使用可能であることを構成が示唆しているため、プロデューサで SASL 認証が使用可能であることが期待されます。
誰もこの問題の経験がありますか?