1

我有一个生产者（Source）将消息写入 Kafka 输出通道，该生产者发送不同类型的对象。在消费者方面 ( Sink) 我想@Streamlistener在同一个输入通道上有多个方法，每个方法都有不同的参数类型，目前我得到它不起作用Duplicate @StreamListener mapping for 'input'。

这是我的消费者代码：

@StreamListener(Sink.INPUT)
public void on(PostUpvotedEvent event) {

}

@StreamListener(Sink.INPUT)
public void on(PostDownvotedEvent event) {

}

有没有比使用单个@StreamListener方法更好的解决方案来测试消息类型以选择要调用的方法？

4

1 回答 1

0

@StreamListener现在不支持在同一个绑定元素上使用多个方法。在您的情况下，最好支持这一点，以便在入站频道上注册多个订阅者。

请在此处创建功能请求

于 2016-10-08T20:41:28.470 回答