Adding NSQ support to the real-time pipeline
Scala Stream Collector
- Bump to 0.11.0 (#3433)
- Update config.hocon.sample to support NSQ (#3294)
- Add NSQ sink (#2093)
- Make Kinesis, Kafka and NSQ config a coproduct (#3449)
- Keep sending records when the Kinesis stream is resharding (#3453)
Stream Enrich
- Bump to 0.12.0 (#3432)
- Update config.hocon.sample to support NSQ (#3339)
- Add NSQ sink (#3337)
- Add NSQ source (#3336)
Common
- Decorrelate CI/CD for Scala Stream Collector and Stream Enrich (#3441)