有两个spring cloud stream应用。一种是生产者向 kafka 生成消息。另一个是处理来自kafka的消息的处理器。现在我们将使用千分尺记录每批的指标。比如producer第一次运行，batch id为1，第二次batch id为2。我们将batch id放在消息头中。对于处理器应用程序，我们希望根据消息的批处理 id 更改标记“batch_id”的值。可能吗？我们做了一些测试，发现标签“batch_id”的值将包含所有已处理的批次 id。你能给出一些指示吗？谢谢，
问问题
1135 次