Hi Anup, This should be possible using the Filter SMT in Kafka Connect together with a custom Predicate which you'd have to write yourself and provide on the plugin path.
See http://kafka.apache.org/documentation.html#connect_predicates and https://rmoff.net/2020/12/22/twelve-days-of-smt-day-11-predicate-and-filter/ for info about Filter and predicates, and https://stackoverflow.com/questions/61742209/smt-does-not-work-when-added-to-connect-mirror-maker-properties-mirrormaker-2 for a MM2-specific example of SMTs Kind regards, Tom On Fri, May 7, 2021 at 8:49 AM Anup Tiwari <[email protected]> wrote: > Hi Team, > > I have a topic which contains JSON data and multiple user click events. I > just wanted to know if we can filter out events based on keys of JSON > before replicating it to some other kafka. > > Regards, > Anup Tiwari >
