protocol buffers - Event Driven Microservices: How to send protobuf messages of different types to one AWS SNS(stream)?

Question

I am planning to develop an Event-Driven Microservices.

1. I create a protobuf project, which defines several types of messages.

   • EmployeeMessage
   • UserMessage
   • ProcessMessage
   • ApplicantMessage

2. Then, I compile the protobuf project to different languages, e.g. Ruby, Golang.

3. Then, the upstream application will push the following type of events to the SNS, the SNS fanout message to multiple SQS, which owned by the different downstream consumers.

4. Then, the downstream application consumes messages from SQS.

Here is a diagram to show the whole architecture.

When implementing it, I realize there is no way. Protobuf messages of different types are posted to SNS, the consumer doesn't know the type of each message and is not able to decode them.

Questions

1. How do you implement your Event-Driven microservices? Does each type of message have its own SNS (stream)?

2. Is there a way to allow me to push different message types to the same SNS (stream)? Do I need to append the message type in front of the payload?

Answer 1

等待大神答复