Hi Kant, Although I'm not aware of existing processor for HTTP2 or NSQ, NiFi has a set of processors for WebSocket since 1.1.0. It enables NiFi to act as a WebSocket client to communicate with a remote WebSocket server, or makes NiFi a WebSocket server so that remote clients access to it via WebSocket protocol.
I've written a blog post about how to use it, I hope it will be useful for your use case: http://ijokarumawak.github.io/nifi/2016/11/04/nifi-websocket/ Thanks, Koji On Wed, Dec 7, 2016 at 3:23 PM, kant kodali <[email protected]> wrote: > Thanks a ton guys! Didn't expect Nifi community to be so good! (Another > convincing reason!) > > Coming back to the problem, We use NSQ a lot (although not my favorite) and > want to be able integrate Nifi with NSQ to other systems such as Kafka, > Spark, Cassandra, ElasticSearch, some micro services that uses HTTP2 and > some micro service that uses Websockets > > (which brings in other question if Nifi has HTTP2 and Websocket processors?) > > Also below is NSQ protocol spec. They have Java client library as well. > > http://nsq.io/clients/tcp_protocol_spec.html > > > On Tue, Dec 6, 2016 at 5:14 PM, Oleg Zhurakousky > <[email protected]> wrote: >> >> Hi Kant >> >> What you’re trying to accomplish is definitely possible, however more >> information may be needed from you. >> For example, the way I understand your statement about “integration with >> many systems” is something like JMS, Kafka, TCP, FTP etc…. If that is the >> case such integration is definitely possible with your “custom system” by >> developing custom Processor and/or ControllerService. >> Processors and ControllerServices are the two main integration points >> within NiFi >> You can definitely find may examples by looking at some of the processors >> (i.e., PublishKafka or ConsumeKafka, PublishJMS or ConsumeJMS etc.) >> >> Let us know if you need more help to guide you through the process. >> >> Cheers >> Oleg >> >> > On Dec 6, 2016, at 7:46 PM, kant kodali <[email protected]> wrote: >> > >> > HI All, >> > >> > I understand that Apache Nifi has integration with many systems but what >> > If I have an application that talks a custom protocol ? How do I integrate >> > Apache Nifi with the custom protocol? >> > >> > Thanks, >> > kant >> >
