Spring Cloud @StreamListener condition deprecated what is the alternative

Question

We have multiple applications consumer listening to the same kafka topic and a producer sets the message header when sending message to the topic so specific instance can evaluate the header and process the message. eg

@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());
}

In Spring Cloud Stream 3.0.0 the @StreamListener is deprecated and I could not find the equivalent of the condition property in Function.

Any suggestion?