innogames / flink-real-time-crmLinks
Demo Flink and Kafka project to show how to react on tracking events in real-time and trigger offer for customer engagement based on campaign configurations. The project also utilizes the Broadcast State Pattern in order to update the rules (campaigns) at runtime without restarting the project, using a dedicated, low-frequency, Kafka topic.
☆14Updated 10 months ago
Alternatives and similar repositories for flink-real-time-crm
Users that are interested in flink-real-time-crm are comparing it to the libraries listed below
Sorting:
- One bite-sized tip or trick for Apache Flink practitioners every day leading up to Christmas Eve 2024.☆26Updated 9 months ago
- A highly efficient daemon for streaming data from Kafka into Delta Lake☆413Updated 4 months ago
- A curated list of Apache Flink learning resources☆93Updated 8 months ago
- 📚 Tech blogs & talks by companies that run Apache Flink in production☆174Updated last month
- Kotlin rules engine DSL for maintaining rules and business logic in code.☆15Updated 3 years ago
- Lakevision is a tool which provides insights into your Apache Iceberg based Data Lakehouse.☆43Updated this week
- Apache Flink Guide☆58Updated 3 years ago
- Apache Spark Kubernetes Operator☆212Updated last week
- ☆59Updated last year
- ☆227Updated last week
- Self-contained demo using Flink SQL and Debezium to build a CDC-based analytics pipeline. All you need is Docker!☆15Updated last year
- Practical examples with Apache Kafka®☆84Updated 2 weeks ago
- Trino load balancer with support for routing, queueing and auto-scaling☆28Updated last week
- Playground for Lakehouse (Iceberg, Hudi, Spark, Flink, Trino, DBT, Airflow, Kafka, Debezium CDC)☆60Updated 2 years ago
- The native Rust implementation for Apache Hudi, with C++ & Python API bindings.☆252Updated last week
- CLI tool to bulk migrate the tables from one catalog another without a data copy☆81Updated 5 months ago
- a curated list of awesome lakehouse frameworks, applications, etc☆35Updated 7 months ago
- Karapace - Your Apache Kafka® essentials in one tool☆547Updated this week
- A sample implementation of stream writes to an Iceberg table on GCS using Flink and reading it using Trino☆21Updated 3 years ago
- Lakekeeper is an Apache-Licensed, secure, fast and easy to use Apache Iceberg REST Catalog written in Rust.☆899Updated this week
- Kotlin helpers to make writing Flink jobs with Kotlin 27% more delightful☆34Updated 9 months ago
- Aiven's JDBC Sink and Source Connectors for Apache Kafka®☆107Updated 3 weeks ago
- Helm charts for Trino and Trino Gateway☆179Updated last week
- MemQ is an efficient, scalable cloud native PubSub system☆138Updated 3 weeks ago
- Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors☆163Updated this week
- Apache DataFusion Comet Spark Accelerator☆1,041Updated this week
- Monitoring and insights on your data lakehouse tables☆30Updated last month
- The Internals of Apache Kafka☆56Updated last year
- Kroxylicious, the snappy open source proxy for Apache Kafka®☆219Updated this week
- Kafka feature for Ktor☆30Updated 2 years ago