나는 httprequest를 얻을 수있는 nifi와 함께 작동하는 webservice를 가지고있다. 테스트를 위해 ReplaceText를 사용하여 응답에 특정 내용을 추가합니다. 이 작동하지만 내 목표는 httpresponse의 내용으로 flowfile (또는 그 값)을 추가하는 것입니다.httpresponse에 아파치 nifi flowfile을 추가하는 방법
usecase는 httprequest (REST Webservice)의 응답으로 정보 (Kafka, HDFS, ...)를 보낼 수 있다는 것입니다.
해결책을 찾고 있었지만 아무 것도 작동하지 않았습니다. Apache NiFi (Hortonworks HDF)의 표준 프로세서를 사용할 수 있습니까?
안부 N3
답변 해 주셔서 감사합니다. 제 문제는 카프카를 사용하고 싶다는 것입니다. 쓴대로 GetKafka는 들어오는 플로우 파일을 허용하지 않기 때문에 불가능합니다. 대신 PutKafka를 사용하는 것에 대해 언급하지만 어떻게해야합니까? 나는 조금 혼란스러워 :? –
Kafka의 경우, POST 요청을 HandleHttpRequest -> PutKafka -> HandleHttpResponse로 이동시켜 Kafka 제작자의 역할을하는 웹 서비스를 만들 수 있다고 말했지만 현재는 웹 서비스를 만들 수있는 방법이 없습니다. 카프카 소비자로 행동하십시오. 들어오는 흐름 파일을 GetKafka에 허용하는 것이 합리적인지 알아야합니다. 현재는 소스 프로세서입니다. –
그래서 HttpRequest를 기반으로 카프카에서 무언가를 보낼 수있는 옵션이 없습니까? 흠 ... MergeContent 또는 ReplaceText와 함께 작동해야합니까? 해봤지만 작동하지 않습니다. –