Hello there, I am having a data into one topic and I have Sink Connector through which all messages get streamed to an application in the ecosystem. I need to filter and send messages only when one field is greater than 50. Message is in JSON format. For eg. { "value": { "value1": { "name"…

Hi @prashant4145 , You can do this using Single Message Transform: [image] 🎄 Twelve Days of SMT 🎄 - Day 11: Predicate and Filter

Thanks alot @rmoff for the help. It will really help alot.

Kafka message filtering based on a field from message

rmoff 11 October 2021 14:52 2

You can do this using Single Message Transform:

Topic		Replies	Views
Single Message Transform - Predicate & Filter Kafka Connect	1	3727	9 March 2022
New blog: 🎄 Twelve Days of SMT 🎄 - Day 11: Predicate and Filter Kafka Connect	1	3494	9 February 2021
Kafka Connect JMESPath: Expressive content-based record filtering Kafka Connect	2	5015	17 March 2021
Apply filter to messages from kafka topic before sink connector picks up ksqlDB	2	4146	26 November 2022
Filter on nested JSON record Kafka Streams	3	3680	16 July 2021