弹簧靴卡夫卡批量转发

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) {

    return data;

}

（其中 是反序列化程序创建的类型）。String