I have been looking into designing an actor system using proto actor and Go.
I would like to include a kafka consumer, but I have been trying to understand how the communication would work with the parent/child relationship with the data from kafka.
It makes sense to me that i should have a child actor that is a kafka consumer, also a kafka parent that managed how many consumers to create based on partitions.
The idea is the unbound kafka data consumed is then passed to Group 1/2 actors which would send data to child actors, the data received from kafka would contain an ID which is relevant to only one child actor and that child would update its state.
My question is how would the kafka child actors data be sent to Group 1/2 actors? Should it be a defined "route" and Group 1/2 actors broadcast the messages to all children, then the children filter on id? Or should the data propagate back up the hierarchy to the manager and then to Group 1/2?
