1、kafka结合springboot开发。
2、生产消息的系统有多个，可能会动态的改变消费系统的个数。举例：A、B、C这3个系统生产消息后分别想让不同的系统使用广播模式消费消息。A想要系统1、2、3消费同一个消息，B想要系统2、3、4、5消费同一个消息，C想要系统1、2、5、6消费同一个消息。这样消费组的个数相当于在动态改变着，可能后面新增或减少，实际环境中生产消息的系统有几十个，消费消息的系统也有几十个，这种网上完全找不到代码案例，都是简单的案例或写死的。求指导代码该怎么写！太复杂了完全没思路！