java - 处理从一个主题到同一主题的流(循环处理)

Question

我在处理从一个主题到同一主题(称为“餐厅”)的流时遇到问题。

如果我制作不同的主题，一切似乎都工作正常。但是，如果我生成“餐厅”主题，则事件似乎没有被注册。我还可以查看流，并且在所有情况下我都可以看到流中的正确事件。

餐厅流有事件(订单)。处理器对它们进行丰富，并将它们以“enrichedOrder”的名称发送回餐厅。

final StreamsBuilder builder = new StreamsBuilder();

KStream<String, Event>[] source = builder.stream("restaurant",consumed)
  .branch(
    (key, value) -> value.name.equals("order"), 
    (key, value) -> true
  );

  source[0].mapValues( (value)->{value.name="enrichedOrder"; return value;} )
    .to("restaurant");

具有“enrichedOrder”事件的餐厅主题。

这可能吗？

我正在使用 Confluence 云平台和 kafka-streams API 2.3。

Answer 1

事实证明，在实际代码中一切正常。但由于某种原因，Confluence Web 界面没有显示这些新事件。 (我正在使用 Confluence Web 界面来监控该主题)。