我有一个应用程序，它接收一个被拆分成更小部分的事件。
每个零件表示有多少零件及其零件值。
我需要将重构的事件发布到下游应用程序。
在任何一个时刻，飞行中应该只有少量的事件。
我考虑使用三个主题：
接收部分的主题。
构建事件的压缩主题。
发布已完成事件的主题。
在启动时，我的应用程序会将压缩的主题含糊不清，并从此主题继续轮询。
收到新零件后，我的应用程序会将其保存到“已接收零件”主题，并更新压缩的主题。
一旦事件完成，我将发布到第三个主题，并从压缩的主题中删除该事件。
Kafka有没有比这更简单的机制，或者我应该去别的地方看看？
谢谢。