You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@streampipes.apache.org by GitBox <gi...@apache.org> on 2021/05/07 03:00:44 UTC

[GitHub] [incubator-streampipes-extensions] mohanvive opened a new pull request #44: Add extension to send events to NATS broker

mohanvive opened a new pull request #44:
URL: https://github.com/apache/incubator-streampipes-extensions/pull/44


   This PR adds support to publish events to NATS broker from Streampipes [1]. 
   
   <img width="1494" alt="Screenshot 2021-05-07 at 08 18 39" src="https://user-images.githubusercontent.com/7523274/117391542-c1746b00-af0d-11eb-9d15-d176a294bd70.png">
   
   Fixes: https://issues.apache.org/jira/browse/STREAMPIPES-354
   
   This PR only provides support for the NATS broker. It would be good to add support for the NATS streaming broker as well, but that specific project will be deprecated, and there is an upgraded streaming broker called "JetStream" is at the tech-preview level. I'll send a PR for that support once it is graduated.
   
   [1] https://nats.io/
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [incubator-streampipes-extensions] mohanvive commented on pull request #44: [STREAMPIPES-354] Add extension to send events to NATS broker

Posted by GitBox <gi...@apache.org>.
mohanvive commented on pull request #44:
URL: https://github.com/apache/incubator-streampipes-extensions/pull/44#issuecomment-835252188


   > Hi @mohanvive this is a cool component.
   > Would it be possible to provide a docker-compose file for a NATS broker in our CLI [1].
   > Then it is easy for developers in the community to test the sink. Some examples for such services can be found here: https://github.com/apache/incubator-streampipes-installer/tree/master/cli/deploy/standalone
   > 
   > I agree with @grainier an adapter for NATS would also be very helpful. Just write me if you need some help.
   > 
   > We also have a new API to define Pipeline Elements. With this API only one class is required instead of three. One example can be found here: https://github.com/apache/incubator-streampipes-extensions/blob/dev/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java
   > I hope this will ease future developments.
   > 
   > Philipp
   
   Thanks. Added in https://github.com/apache/incubator-streampipes-installer/pull/13 .


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [incubator-streampipes-extensions] tenthe commented on pull request #44: [STREAMPIPES-354] Add extension to send events to NATS broker

Posted by GitBox <gi...@apache.org>.
tenthe commented on pull request #44:
URL: https://github.com/apache/incubator-streampipes-extensions/pull/44#issuecomment-835211696


   Hi @mohanvive this is a cool component.
   Would it be possible to provide a docker-compose file for a NATS broker in our CLI [1]. 
   Then it is easy for developers in the community to test the sink. Some examples for such services can be found here: https://github.com/apache/incubator-streampipes-installer/tree/master/cli/deploy/standalone
   
   I agree with @grainier an adapter for NATS would also be very helpful. Just write me if you need some help.
   
   We also have a new API to define Pipeline Elements. With this API only one class is required instead of three. One example can be found here: https://github.com/apache/incubator-streampipes-extensions/blob/dev/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java
   I hope this will ease future developments.
   
   Philipp


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [incubator-streampipes-extensions] mohanvive commented on pull request #44: Add extension to send events to NATS broker

Posted by GitBox <gi...@apache.org>.
mohanvive commented on pull request #44:
URL: https://github.com/apache/incubator-streampipes-extensions/pull/44#issuecomment-834026121


   @grainier @wipatrick @dominikriemer 


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [incubator-streampipes-extensions] dominikriemer merged pull request #44: [STREAMPIPES-354] Add extension to send events to NATS broker

Posted by GitBox <gi...@apache.org>.
dominikriemer merged pull request #44:
URL: https://github.com/apache/incubator-streampipes-extensions/pull/44


   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org