我已将消费者配置为批量接受来自某个主题的消息。如何将其转发到新主题?
我希望每个使用的消息都作为它自己的消息进行转发。因此,消耗 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
最佳答案
不支持该功能。无论如何,您都无法将 ConsumerRecord
发送到 Producer
。
不过这可行
@KafkaListener(id = "foo", topics = "input")
@SendTo("output")
public List<String> consume(List<String> data) {
return data;
}
(其中 String
是反序列化器创建的类型)。
关于java - Spring Boot Kafka 批量转发,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55580534/