@StreamListener(target = Sink.INPUT, condition = "headers['eventType']=='EmployeeTransferredEvent'"

Hi @sakshi_123,

Looking at this I think the cleanest option would be to go with option #1 that I mentioned previously. This was the option that started with “Create a topic republisher that reads all the messages and publishes them back out on more detailed topic hierarchy”. By going that route you can put the items that you’d like to filter on now, and think you might need to filter on in the future, into the topic hierarchy of the republished messages. This will allow you to filter on those items in your topic subscriptions (you can have multiple per app) and avoid having an app that needs to act as an orchestrator between your different web apps. This will reduce coupling, and allow the Event Broker to take on the responsibility of maintaining order across your events.