dursunkoc / flink-kafka-sample
A Basic Flink Application Consuming & Aggregating Kafka Messages
☆10Updated 5 years ago
Alternatives and similar repositories for flink-kafka-sample:
Users that are interested in flink-kafka-sample are comparing it to the libraries listed below
- Flink Examples☆39Updated 8 years ago
- Experiments with Apache Flink.☆5Updated last year
- Examples of all Machine Learning Algorithm in Apache Spark☆15Updated 7 years ago
- Sample processing code using Spark 2.1+ and Scala☆51Updated 4 years ago
- ☆105Updated 5 years ago
- ☆17Updated 2 years ago
- Examples of Spark 3.0☆47Updated 4 years ago
- Spark with Scala example projects☆34Updated 5 years ago
- A sample project for KSQL along with debezium and kafka connect☆15Updated 2 years ago
- A consumer of a Kafka topic based on Flink☆12Updated 2 years ago
- Code for the fictitious food delivery company GottaEat used in the Pulsar In Action book☆17Updated 2 years ago
- Infrastructure automation to deploy Hadoop,Hive,Spark,airflow nodes on a docker host☆20Updated 6 years ago
- Spark structured streaming with Kafka data source and writing to Cassandra☆62Updated 5 years ago
- Flink performance tests☆28Updated 5 years ago
- The Internals of PySpark☆25Updated last month
- 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
- Spark Streaming HBase Example☆22Updated 8 years ago
- Apache iceberg Spark s3 examples☆19Updated 11 months ago
- Demo code for implementing and showcasing a Fraud Detection Engine with Apache Flink.☆31Updated 2 years ago
- Spark stream from kafka(json) to s3(parquet)☆15Updated 6 years ago
- Get started with Apache Beam and Flink☆42Updated 8 years ago
- Scalable CDC Pattern Implemented using PySpark☆18Updated 5 years ago
- Profiling Spark Applications for Performance Comparison and Diagnosis☆16Updated 6 years ago
- Plot live-stats as graph from ApacheSpark application using Lightning-viz☆18Updated 7 years ago
- ☆25Updated 5 months ago
- This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.☆41Updated 8 years ago
- Configuration options and instructions on how to add JanusGraph to ambari as a service☆9Updated 6 years ago
- No longer maintained and soon to be deleted☆76Updated 5 years ago
- Streaming using Flink to connect Kafka and Elasticsearch☆30Updated 8 years ago
- Code from an Apache Flink™ talk I regularly give☆44Updated 5 years ago