BrooksIan / Flink2Kafka
A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink
☆20Updated last year
Alternatives and similar repositories for Flink2Kafka:
Users that are interested in Flink2Kafka are comparing it to the libraries listed below
- Pipeline library for StreamSets Data Collector and Transformer☆33Updated 2 years ago
- ☆29Updated last week
- HDF masterclass materials☆28Updated 9 years ago
- Connect DBVisualizer to Hortonwork HiveServer2☆9Updated 10 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
- Demos for Nessie. Nessie provides Git-like capabilities for your Data Lake.☆29Updated last week
- Spark Streaming HBase Example☆22Updated 9 years ago
- Eskimo is a state of the art Big Data Infrastructure and Management Web Console to build, manage and operate Big Data 2.0 Analytics clust…☆26Updated last year
- Scalable CDC Pattern Implemented using PySpark☆18Updated 5 years ago
- ☆27Updated last year
- Demonstration of a Hive Input Format for Iceberg☆26Updated 4 years ago
- ☆14Updated 2 months ago
- Spark 3.0.0 Structured Streaming Kafka Avro Demo☆15Updated 2 years ago
- Apache NiFi 1.5/1.6/1.9.2+ Processor to produce DDL☆11Updated 2 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
- A small project to show how to add lineage to Atlas when using Spark as ETL tool☆12Updated 8 years ago
- Mastering Spark for Data Science, published by Packt☆47Updated 2 years ago
- A bridge to Apache Atlas for provenance metadata created in course of using Apache NiFi☆15Updated 2 years ago
- Code for the fictitious food delivery company GottaEat used in the Pulsar In Action book☆18Updated 3 years ago
- Collection of examples integrating NiFi with stream process frameworks.☆59Updated 8 years ago
- ☆39Updated 6 years ago
- The Internals of Spark on Kubernetes☆71Updated 3 years ago
- ☆10Updated 2 years ago
- Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data strea…☆26Updated 2 years ago
- Flink dynamic CEP demo☆18Updated 3 years ago
- Examples of Spark 3.0☆47Updated 4 years ago
- Interactive Notebooks that support the book☆40Updated 4 years ago
- ☆13Updated last year
- ☆24Updated 8 months ago
- Sample processing code using Spark 2.1+ and Scala☆52Updated 4 years ago