For anyone looking to support multiple message patterns on one message bus, this is what you want to check out.
In AWS terms, it’s like SNS/SQS/Kinesis all rolled into one bus & very intuitive to work with.
https://nightlies.apache.org/flink/flink-docs-master/docs/de...