小编Mic*_*Mok的帖子

我们有多个应用程序消费者监听同一个 kafka 主题，并且生产者在向主题发送消息时设置消息标头，以便特定实例可以评估标头并处理消息。例如

@StreamListener(target=ITestSink.CHANNEL_NAME,condition="headers['franchiseName'] == 'sydney'")
public void fullfillOrder(@Payload TestObj message) {
    log.info("sydney order request received message is {}",message.getName());
}

在 Spring Cloud Stream 3.0.0 中，@StreamListener 已被弃用，我无法在 Function 中找到条件属性的等效项。

有什么建议吗？