GitPlanet

Cheap and reliable Node.js hosting starts at $3/month, and $1/month static HTML hosting

Created with love in Canada, visit hostnodejs.com today

Feel like to post an Ad? Learn Details
All Projects → mkuthan → example-kafkastreams

mkuthan / example-kafkastreams

Licence: other
Kafka Streams DSL vs Processor API

Programming Languages

scala
5932 projects

Labels

kafka-streams

Projects that are alternatives of or similar to example-kafkastreams

Willa
A Clojure DSL for Kafka Streams
Stars: ✭ 97 (+506.25%)
Mutual labels:  kafka-streams
A Kafka Story
Kafka ecosystem ... but step by step!
Stars: ✭ 148 (+825%)
Mutual labels:  kafka-streams
Hivemq Mqtt Tensorflow Kafka Realtime Iot Machine Learning Training Inference
Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required
Stars: ✭ 204 (+1175%)
Mutual labels:  kafka-streams
Java Kafka Client
OpenTracing Instrumentation for Apache Kafka Client
Stars: ✭ 101 (+531.25%)
Mutual labels:  kafka-streams
Kafka Tutorials
Kafka Tutorials microsite
Stars: ✭ 144 (+800%)
Mutual labels:  kafka-streams
Kafka Streams Dotnet
.NET Stream Processing Library for Apache Kafka 🚀
Stars: ✭ 173 (+981.25%)
Mutual labels:  kafka-streams
Kspp
A high performance/ real-time C++ Kafka streams framework (C++17)
Stars: ✭ 80 (+400%)
Mutual labels:  kafka-streams
Data Accelerator
Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.
Stars: ✭ 247 (+1443.75%)
Mutual labels:  kafka-streams
Azkarra Streams
🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.
Stars: ✭ 146 (+812.5%)
Mutual labels:  kafka-streams
Strimzi Kafka Operator
Apache Kafka running on Kubernetes
Stars: ✭ 2,833 (+17606.25%)
Mutual labels:  kafka-streams
Kukulcan
A REPL for Apache Kafka
Stars: ✭ 103 (+543.75%)
Mutual labels:  kafka-streams
Awesome Kafka
A collection of kafka-resources
Stars: ✭ 116 (+625%)
Mutual labels:  kafka-streams
Mockedstreams
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Stars: ✭ 184 (+1050%)
Mutual labels:  kafka-streams
Logisland
Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.
Stars: ✭ 97 (+506.25%)
Mutual labels:  kafka-streams
Kafka With Akka Streams Kafka Streams Tutorial
Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka
Stars: ✭ 204 (+1175%)
Mutual labels:  kafka-streams
Microservice Patterns
Code to share the knowledge I gained while designing and implementing micro services
Stars: ✭ 87 (+443.75%)
Mutual labels:  kafka-streams
Streamline
StreamLine - Streaming Analytics
Stars: ✭ 151 (+843.75%)
Mutual labels:  kafka-streams
kafka-streams-plumber
Plumber, for your dirtiest Kafka streaming jobs
Stars: ✭ 24 (+50%)
Mutual labels:  kafka-streams
Kafka Ui
Open-Source Web GUI for Apache Kafka Management
Stars: ✭ 230 (+1337.5%)
Mutual labels:  kafka-streams
Kafka Streams Scala
Thin Scala wrapper around Kafka Streams Java API
Stars: ✭ 192 (+1100%)
Mutual labels:  kafka-streams
View All Similar Projects ➔

Kafka Streams DSL vs Processor API

Build Status

Features

  • Warm-up Processor API exercise, see DeduplicationExample.
  • Clickstream join topology implemented using DSL and Processor API, see ClickstreamJoinExample.
  • Processor API version is up to 10 times more efficient than DSL version.
  • Examples are configured with Embedded Kafka and does not require any additional setup.
  • Implemented with Kafka 1.0

Missing Features

  • Tests
  • Closing WindowStoreIterator (it is not feasible with javaIt.asScala converter)

References

Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].