我是 Spring-Integration 的新手，正在寻找以下任务的解决方案。
我们尝试创建一个 MQTT-Consumer（基于mqtt 入站通道适配器），它接收来自多达 50 个发布者的 7 个主题的消息。
由于适配器按顺序处理消息，因此必须扩展并行处理，或者获取代理丢弃的其余消息。
扩展的第一个想法是每个主题有一个适配器，并带有相应的转换器。它可以很好地消耗来自一个发布者的消息，但不能承受如此多的发布者，使用排队或直接出站通道。
目前正在考虑将执行程序通道与每个主题的消息处理程序（自己的转换器）的数量一起使用。之后的那些将他们的结果传送到相应的排队通道中，这将允许批量处理和传播消息。
但是，我不确定为每个主题创建单个适配器是否是一个好主意，并且正在寻找有关架构改进的任何建议。提前致谢！