我已將使用者配置為批量接受來自主題的消息。如何將其轉發到新主題？我希望每個使用的消息都像它自己的消息一樣轉發。因此，消耗的 X 個消息量將產生 X 個消息量。這是我目前的設置：@KafkaListener(topics = "input")@SendTo("output")public ConsumerRecords consume(ConsumerRecords records) { // Do things return records;}下面是引發的異常：網站：找不到適用于 Java.util.Array 列表類的方法
1 回答
慕容森
TA貢獻1853條經驗 獲得超18個贊
不支持該功能。在任何情況下，都不能將 發送到 .ConsumerRecordProducer
不過，這有效
@KafkaListener(id = "foo", topics = "input")
@SendTo("output")
public List<String> consume(List<String> data) {
return data;
}
（其中 是反序列化程序創建的類型）。String
添加回答
舉報
0/150
提交
取消