Hello everyone, I started using Ignite lately. Part of my work involves Pub/Sub, thus I created a pub/sub streamer. Pub/Sub is pretty close to Kafka. Here's how the streamer works. Every node creates an instance of a Pub/Sub client. The clients subscribe to the same topic using the same subscription name. A message is being sent and one of the nodes will receive the message, process it and then forward it to Ignite using the extractor provided.
Any thoughts? *Emmanouil Gkatziouras* https://egkatzioura.com/ | https://www.linkedin.com/in/gkatziourasemmanouil/ https://github.com/gkatzioura
