[PROJECT IS NO LONGER MAINTAINED] Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.
💱 Trading application written in Scala 3 that showcases an Event-Driven Architecture (EDA) and Functional Programming (FP)
Lego bricks to build Apache Kafka serializers and deserializers
A REPL for Apache Kafka
Event sourcing for Akka Streams
Oh you know, just a coupla, two, tree Kafka Streams in Scala
A native Kafka protocol proxy for Apache Kafka
A Kafka metric sink for Apache Spark
Ingest, Enrich, Sessionize, aggregate, and store clickstream Data in real time
Simple big data pipeline
Master Thesis: Online Anomaly Detection and Root Cause Analysis. A system based on Apache Kafka and Flink
Building POC of streaming pipeline with Flink, Kafka, Pinot
Exasol Kafka Extension for accessing Apache Kafka
Wait for it.... Kafka Examples!
Real-Time IoT data Simulator written in Scala lang to feed kafka Producer
A library having Scala examples for Apache Flink
Random Traffic Data set generator (Default: sends generated data to a Kafka topic)
Add a description, image, and links to the apache-kafka topic page so that developers can more easily learn about it.
To associate your repository with the apache-kafka topic, visit your repo's landing page and select "manage topics."