java - Spring Boot Kafka 批量转发

Question

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

我希望每个使用的消息都作为它自己的消息进行转发。因此，消耗 X 数量的消息将产生 X 数量的消息。

这是我当前的设置:

@KafkaListener(topics = "input")
@SendTo("output")
public ConsumerRecords consume(ConsumerRecords records) {
  // Do things
  return records;
}

这是抛出的异常:

org.springframework.kafka.KafkaException: No method found for class java.util.ArrayList

Answer 1

不支持该功能。无论如何，您都无法将 ConsumerRecord 发送到 Producer。

不过这可行

@KafkaListener(id = "foo", topics = "input")
@SendTo("output")
public List<String> consume(List<String> data) {
    return data;
}

(其中 String 是反序列化器创建的类型)。