你可以用两种方法中的一种。或者为消息键设置前缀系统，或者将内容放在消息中，以允许使用者避免其生成的消息。
至于您是否应该这样设计它，这取决于您的消息流量。如果您不是用事件来抨击它，那么最好考虑使用节俭之类的方式让消息组件进行双向通信。相对于其复杂性，kafka真正擅长的地方是当您需要生成和使用大量数据时。你可能不是这样。
例如，kafka的一个常见用例是将其与storm、apex或samza等服务连接起来，以便对数百gb甚至tb的数据进行分布式处理。如果您的系统有高吞吐量的需求，那么该体系结构将是一个很好的选择，可以作为kafka处理消息的起点。使用storm，如果需要将消息发送回以进行重新处理，则始终可以使用kafka bolt将消息重新发布到kafka中，以确保消息得到完全重新处理。