私はhttprequestを取得して応答できるnifiで動作するwebserviceを持っています。テストのために、ReplaceTextを使用して特定のコンテンツをレスポンスに追加します。これは動作しますが、私の目標は、httpresponseの内容としてフローファイル（またはその値）を追加することです。httpresponseにapache nifi flowfileを追加するには
私は、httprequest（REST Webservice）の応答として（Kafka、HDFSなどの）情報を送信できます。
解決策を探してテストしていましたが、何も機能しません。 Apache NiFi（Hortonworks HDF）の標準プロセッサで実現可能ですか？
よろしく N3
あなたは戻ってHandleHttpResponseを通じて任意のフローファイルの内容を送信することができるはずです。 - > FetchHDFS - > HandleHttpResponse
あなたが操作するため、FetchHDFS前に、いくつかのより多くのものを行う必要があるかもしれません
HandleHttpRequest：HDFSからファイルを返すWebサービスを作成するために、たとえば、次のような何かを行うことができるはずそのデータは一般的なアプローチになります。キーは、入ってくるフローファイルを受け入れるプロセッサが必要なことです。そのため、KafkaではPutKafkaでは同じことをやり取りできますが、GetKafkaでは受け付けないフローファイルを受け入れることができないためです。
このGitHubのレポは、ローカルディスクからファイルを取得するWebサービスの例があります：https://github.com/bbende/nifi-streaming-examples
は、「ログレベルのための要求を処理する」と言う最初の画像を参照してください。
回答ありがとうございます。私の問題は、私がKafkaを使いたいということです。あなたが書いたように、GetKafkaは入ってくるフローファイルを受け入れないので、不可能です。あなたは代わりにPutKafkaを使用すると言いますが、どうですか？私は少し混乱している：？カフカのために –
が、私はあなたがPOSTリクエストがHandleHttpRequestに行くことによってカフカのプロデューサーを務めたWebサービスを作ることができると言っていた - > PutKafka - > HandleHttpResponseが、しかし現在は希望Webサービスを作成する方法はありませんカフカの消費者として行動する。入ってくるフローファイルをGetKafkaに許可することが理にかなっているかどうかを確認する必要があります。現在、GetKafkaはソースプロセッサです。 –
だから、HttpRequestのに基づいてカフカから何かを送信するオプションはありませんか？ Hm ... MergeContentやReplaceTextでうまくいくのでしょうか？私はそれを試したが、うまくいかない。 –