我们正在构建一个系统，以可控和可预测的速度将数据从生态系统中的一个点移动到另一个点。系统基本上有一个主Kafka主题，它获取n种类型的消息。然后，使用此主题的代理根据消息负载主题将消息放入n个工作队列中的一个。然后，这些工人队列中的工人实际在做这项工作。
现在我想实现控制旋钮，比如-暂停/恢复/限制来自代理的1种类型的消息。假设代理和工作人员之间没有通信，我怎么做呢。我是否应该为代理编写这些消息的每个worker设置一个单独的“系统事件”主题？或者最好在顶层也有n个队列？