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

Hey @arpit_k - looks like your question might not be related to this post (filter messages based on header). If that’s the case can you please start a new discussion post over here https://solace.community/post/discussion and make sure to include the tags as well :slight_smile: