問題タブ [kafka-rest]
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 - Spotify Kafka イメージで cp-rest-proxy に失敗する Zookeeper 接続
Spotify が提供するカフカ イメージを使用して、カフカをローカルで実行しています。私は現在、画像と一緒に使用しようとしていcp-kafka-restますschema-registry。
この問題を解決するには助けが必要です:
エラー (ログ グループ: kafka_rest_1_609fd108dcf4)
[main-SendThread(zookeeper:2181)] WARN org.apache.zookeeper.ClientCnxn - サーバー Zookeeper:2181 のセッション 0x0、予期しないエラー、ソケット接続を閉じて再接続を試みています
Docker Compose
apache-kafka - http 経由でストリーミング データを Kafka に取り込む
私は、Kafka とストリーミング データ全般について非常に初心者です。私がやろうとしているのは、http 経由で kafka に送信されるデータを取り込むことです。調査の結果、コンフルエントな REST プロキシにたどり着きましたが、動作させることができません。
私が現在持っているのは、docker コンテナー内の kafkamanager を使用して、単一のノードと単一のブローカーで実行されている kafka です。
残念ながら、マシンに十分なメモリがないため、docker を使用して完全なコンフルエント プラットフォームを実行することはできません。
本質的に私の質問は次のとおりです。データが http を介して kafka によって取り込まれる開発環境をセットアップする方法は?
どんな助けでも大歓迎です！
json - Kafka - Rest サービス メッセージを変換して kafka トピックに取り込む方法は?
私はカフカコミュニティに不慣れで、難しい質問に直面しています。本文がjsonメッセージであるRest Webサービスを介して互いに通信する2つのアプリケーションがあります。
これら 2 つのアプリケーションの間のミドルウェアとして kafka を使用し、アプリケーションへの影響を最小限またはゼロにするにはどうすればよいですか?
これは私の現状のシナリオです:
私の将来のシナリオ:
ヘッダーとボディを変換するために STM またはインターセプターを使用することを考えました。
そのようにすることは可能ですか？私は体を次のように変換しなければならないことを知っています:
に：
基本的に、私の変換は、各レコードのフィールドではなく、メッセージの最初と最後を変更します。
誰かがそのようなことをしたことがありますか、または私がどちらに行くべきかの兆候がありますか?