Streaming Analytics platform, built with Apache Flink and Kafka

Colaberry Scala immersion training

This project can be used as a tutorial showing to to use twiiter4j of twitter to stream. Use Apache Kafka as a producer, and Apache Spark as a consumer

☁️ Simple akka-kafka producer packaged for k8s and Confluent Cloud

This is a basic example to show CEP in flink with kafka

Robot Inventory Exercise using Scala, Play2, Kafka and Cassandra

Akka Streams - Kafka - Spark Streaming

Place where i put all my frequently used spark/hadoop/kafka/big data stuff

An end-to-end batch data pipeline for e-commerce analytics, built with Scala, Spark, HDFS, Hive, Postgres, and Jenkins. The system is enhanced with a parallel streaming pipeline using Kafka for real-time Twitter trend analysis.

A get-started guild for SMACK on DC/OS

Scala applicaton to get familiar with the workflow of Apache Kafka, its workflow. I used also Akka-Stream, Akka-Actor.

Monix integration with Kafka

Example of Streaming Spark semantics when used with Kafka

Repository for the project in Supercomputing for Big Data course at TU Delft. Apache Spark and Apache Kafka were used to perform both batched and stream processing on GDelt data.

Simple online learning example using Apache Kafka

Alert when a new version of a repository is released

Simple SMACK architecture