The Wayback Machine - http://web.archive.org/web/20201124025606/https://github.com/topics/kafka-streams
Skip to content
#

kafka-streams

Star

Here are 518 public repositories matching this topic...

Language: All
Filter by language
All 518 Java 286 Scala 94 Python 24 Kotlin 20 Shell 11 Clojure 10 JavaScript 9 Jupyter Notebook 8 HTML 6 C# 5
Sort: Best match
Sort options
Best match Most stars Fewest stars Most forks Fewest forks Recently updated Least recently updated

kaiwaehner / kafka-streams-machine-learning-examples

Star

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.

python java open-source machine-learning kafka deep-learning tensorflow h2o keras kafka-client kafka-streams dl4j keras-tensorflow h2oai deeplearning4j ksql
  • Updated Oct 13, 2020
  • Java

microsoft / data-accelerator

Star
Find more good first issues →

kaiwaehner / hivemq-mqtt-tensorflow-kafka-realtime-iot-machine-learning-training-inference

Star

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

python java kubernetes mqtt cloud kafka mongodb tensorflow terraform gcp grpc data-lake confluent hivemq kafka-connect kafka-streams ksql ksqldb tiered-storage tensorflow-io
  • Updated Nov 5, 2020
  • Jupyter Notebook
azkarra-streams

streamthoughts / azkarra-streams

Star
Open

StreamsExecutionEnvironment instances should be able to be registered as component

fhussonnois
fhussonnois commented May 12, 2020

Currenlty a StreamsExecutionEnvironment instance can be registed directly through the AzkarraContext#addExecutionEnvironment method and from the configuration.

The following example shows how to define an environment using configuration :

azkarra {
  // Create a environment for running the WordCountTopology
  environments = [
    {
      name: "dev"
      config = {}
      jo
Read more
good first issue in:runtime type:enhancement

Hurence / logisland

Star

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.

elasticsearch kafka big-data spark cassandra influxdb analytics solr stream-processing pattern-recognition complex-event-processing kafka-streams
  • Updated Nov 23, 2020
  • Java

Improve this page

Add a description, image, and links to the kafka-streams topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the kafka-streams topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.