spring 云流 kafka : 'input' 的重复@StreamListener 映射
spring cloud stream kafka : Duplicate @StreamListener mapping for 'input'
我有一个将消息写入 Kafka 输出通道的生产者 (Source)，该生产者发送不同类型的对象。在消费者方面 (Sink) 我想在同一个输入通道上有多个 @Streamlistener 方法，每个方法都有不同的参数类型，目前它不起作用我得到 Duplicate @StreamListener mapping for 'input'.
这是我的消费者代码：
@StreamListener(Sink.INPUT)
public void on(PostUpvotedEvent event) {
}
@StreamListener(Sink.INPUT)
public void on(PostDownvotedEvent event) {
}
有没有比使用单个 @StreamListener 方法更好的解决方案，该方法将测试消息类型以选择要调用的方法？
现在不支持对同一个绑定元素使用多个 @StreamListener 方法。像您这样在入站频道上注册多个订户的情况下支持这一点会很好。
请创建一个功能请求here
我有一个将消息写入 Kafka 输出通道的生产者 (Source)，该生产者发送不同类型的对象。在消费者方面 (Sink) 我想在同一个输入通道上有多个 @Streamlistener 方法，每个方法都有不同的参数类型，目前它不起作用我得到 Duplicate @StreamListener mapping for 'input'.
这是我的消费者代码：
@StreamListener(Sink.INPUT)
public void on(PostUpvotedEvent event) {
}
@StreamListener(Sink.INPUT)
public void on(PostDownvotedEvent event) {
}
有没有比使用单个 @StreamListener 方法更好的解决方案，该方法将测试消息类型以选择要调用的方法？
现在不支持对同一个绑定元素使用多个 @StreamListener 方法。像您这样在入站频道上注册多个订户的情况下支持这一点会很好。
请创建一个功能请求here