Spring Boot Kafka Batch转发

问题描述 投票:0回答:1

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

我希望每条消费的消息都按照自己的消息进行转发。因此消耗的X消息量将产生X量的消息。

这是我目前的设置:

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

这是抛出的异常:

org.springframework.kafka.KafkaException:找不到类java.util.ArrayList的方法

java apache-kafka spring-kafka
1个回答
2
投票

该功能不受支持。在任何情况下,你不能发送ConsumerRecordProducer

但这很有效

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

(其中String是由解串器创建的类型)。

热门问题
推荐问题
最新问题