{"repo":"caobahuong/kafka-connect-dynamic-filter","free":true,"listed":false,"github":"https://github.com/caobahuong/kafka-connect-dynamic-filter","clone":"git clone https://github.com/caobahuong/kafka-connect-dynamic-filter.git","description":"Kafka Connect SMT that filters Debezium CDC records using a dynamic rule tree - update rules at runtime without restarting the connector.","language":"Java","stars":19,"topics":["cdc","debezium","kafka","kafka-connect","plugins"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"kafka-connect-dynamic-filter 🇺🇸 English · 🇻🇳 Tiếng Việt · 🇨🇳 中文 · 🇯🇵 日本語 --- A Kafka Connect SMT for filtering Debezium CDC records with dynamic conditions update rules at any time without restarting the connector. This document covers features and installation. For a step-by-step deployment walkthrough, see: Deploying kafka-connect-dynamic-filter --- Why This Library? Debezium's built-in Filter SMT requires static Groovy/JS scripts hard-coded into the connector config. Changing a filter means editing the config, redeploying, and restarting the connector disrupting the pipeline each time. For example: suppose your pipeline currently streams only records where ref id is 1, 2, or 3. Adding values 4 and 5 with Debezium Filter requires editing the config, redeploying, restarting the connector, and tolerating pipeline disruption in the meantime. With this library, you update the rule in Redis, a Kafka topic, or a JSON file. The connector picks it up on the very next record no config changes, no restart, no downtime. Debezium Filter (built-in) kafka-connect-dynamic-filter --- --- --- Rule update ❌ Connector restart required ✅ Takes effect on next record Rule language Groovy / JS hardcoded Dynamic JSON Rule source Config file Redis, Kafka topic, File, or custom Compound conditions Write code AND / OR / nested via JSON --- Modules The project ships a core library for building your own loader. The modules below are ready-made implementations provided by the author. Module Wher","default_branch":null,"files":null,"tree":[],"storefront":"/r/caobahuong","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/caobahuong/kafka-connect-dynamic-filter/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}