要求：
假设我收到来自3个组织的消息，并希望由不同的消费者分别/有序地处理它们。
m—来自给定组织的多条消息示例m1:来自Oragnization 1的多条消息
p-分区c-耗电元件
对于给定的主题和消费者群体。

m1  P1  c1
m2  P2  c2
m3  P3  c3

现在，稍后在运行时新的组织加入。因此，它应该是新条目，即新分区/新使用者

m1  P1  c1
m2  P2  c2
m3  P3  c3

m4  p4  c4

此外，如果任何消费者因任何原因死亡，则不应将该部分分配给其他消费者，而应使用新的消费者来代替最近丢失的消费者。其想法是保持m-->p-->c之间的1:1关系，以便跟踪来自哪个组织的信息。
示例：如果c3死于，则应立即用c5替换，而不丢失数据，并从c3离开的位置开始消耗，依此类推。
我使用的是spring集成kafka 1.2.1.release
有可能吗？寻找最好的解决方案。如果能得到上面提到的版本（1.2.1）的生产者和消费者的代码片段/示例，那就太好了。非常感谢。