NATS Messaging Connector

[danielkec]

• [ ] reactive connection with stan.java
• [ ] backpressure - possible to use MaxPubAcksInFlight and MaxInFlight?
• [ ] ack
• [ ] durable subscriptions - equivalent of consumer group in kafka?
• [ ] testing - mocking as only alternative?

[wallyqs]

Might be better to look into using the JetStream engine from NATS which is the next gen of NATS Streaming (https://github.com/nats-io/nats.java#jetstream)