Kafka Connect has the Filter SMT which can be used with a predicate to filter out certain messages, see https://kafka.apache.org/documentation/#connect_predicates
Kinds regards, Tom On Wed, Mar 10, 2021 at 8:46 AM raman gugnani <ramangugnani....@gmail.com> wrote: > HI Team, > > I want to filter out some of the kafka messages from source kafka cluster > to destination kafka cluster via some logic. > > Logics to filter > > 1. If possible to filter data on the basis of static data. > 2. If possible, filter data dynamically based on a custom provider (some > jar or some other way around). > > > Looking to do the same via any of the below features > > 1. Kafka mirror > 2. Kafka Connect > 3. Kafka Streams. > > -- > Raman Gugnani >
