弹簧靴卡夫卡批量转发

Question

我已将使用者配置为批量接受来自主题的消息。如何将其转发到新主题？

我希望每个使用的消息都像它自己的消息一样转发。因此，消耗的 X 个消息量将产生 X 个消息量。

这是我目前的设置：

@KafkaListener(topics = "input")

@SendTo("output")

public ConsumerRecords consume(ConsumerRecords records) {

  // Do things

  return records;

}

下面是引发的异常：

网站：找不到适用于 Java.util.Array 列表类的方法

Answer 1

不支持该功能。在任何情况下，都不能将 发送到 .ConsumerRecordProducer不过，这有效@KafkaListener(id = "foo", topics = "input")@SendTo("output")public List<String> consume(List<String> data) {&nbsp; &nbsp; return data;}（其中 是反序列化程序创建的类型）。String