BrooksIan / Flink2Kafka
A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink
☆20Updated last year
Related projects ⓘ
Alternatives and complementary repositories for Flink2Kafka
- Pipeline library for StreamSets Data Collector and Transformer☆32Updated last year
- ☆27Updated 3 weeks ago
- Ecosystem website for Apache Flink☆12Updated 9 months ago
- A bridge to Apache Atlas for provenance metadata created in course of using Apache NiFi☆15Updated last year
- ☆39Updated 5 years ago
- HDF masterclass materials☆28Updated 8 years ago
- ☆27Updated 9 months ago
- Demonstration of a Hive Input Format for Iceberg☆26Updated 3 years ago
- Demos for Nessie. Nessie provides Git-like capabilities for your Data Lake.☆28Updated 2 weeks ago
- This is a real-time dashboard example using Spark Streaming and Node.js☆26Updated 7 years ago
- Sample processing code using Spark 2.1+ and Scala☆51Updated 4 years ago
- Spark Streaming HBase Example☆22Updated 8 years ago
- A small project to show how to add lineage to Atlas when using Spark as ETL tool☆12Updated 7 years ago
- Lab project to showcase Flink's performance differences between using a SQL query and implementing the same logic via the DataStream API☆14Updated 4 years ago
- A modern real-time streaming application serving as a reference framework for developing a big data pipeline, complete with a broad range…☆41Updated 4 years ago
- Flink dynamic CEP demo☆17Updated 2 years ago
- Kafka, Spark Streaming, Kudu integration examples☆17Updated 6 years ago
- Scalable CDC Pattern Implemented using PySpark☆18Updated 5 years ago
- Code and documentation for the demonstration example of the real-time bushfire alerting with the Complex Event Processing (CEP) in Apache…☆26Updated 6 years ago
- Collection of examples integrating NiFi with stream process frameworks.☆56Updated 8 years ago
- ☆8Updated 6 years ago
- ☆15Updated 2 years ago
- Apache-Spark based Data Flow(ETL) Framework which supports multiple read, write destinations of different types and also support multiple…☆26Updated 3 years ago
- The Internals of Spark on Kubernetes☆70Updated 2 years ago
- Flink Examples☆39Updated 8 years ago
- Infrastructure automation to deploy Hadoop,Hive,Spark,airflow nodes on a docker host☆20Updated 5 years ago
- ☆47Updated 4 years ago
- Serializable ACID transactions on streaming data☆23Updated 2 years ago