This is your work, valued

Munich, Germany

Kai Waehner

Elite
@kaiwaehner

Advisory Field CTO (own company) and Global Field CTO at Kestra. Author, speaker. Data integration, orchestration, agentic AI. www.kai-waehner.de

kafka-streams-machine-learning-examples. 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.

911

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

419

ksql-udf-deep-learning-mqtt-iot. Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

306

kafka-connect-iot-mqtt-connector-example. Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data

215

tensorflow-serving-java-grpc-kafka-streams. Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

149

python-jupyter-apache-kafka-ksql-tensorflow-keras. Making Machine Learning Simple and Scalable with Python, Jupyter Notebook, TensorFlow, Keras, Apache Kafka and KSQL

97

ksql-fork-with-deep-learning-function. Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example

79

iiot-integration-apache-plc4x-kafka-connect-ksql-opc-ua-modbus-siemens-s7. Industrial IoT (IIoT) Integration and Data Processing with Apache PLC4X, Kafka Connect, KSQL (OPC-UA, Modbus, Siemens S7)

34

ksql-machine-learning-udf. Confluent KSQL Addon - User Defined Function (UDF) for Machine Learning

11

ksql-apache-kafka-quickstart-step-by-step-example. KSQL Step-by-step tutorial using the basic functions of Apache Kafka's Streaming SQL Engine

10

kafka-connect-smt-string-filter. Single Message Transformation (SMT) for Kafka Connect to Filter String Messages

8

MavenCamelScala. A working

8

kafka-streams-course. Learn Kafka Streams with several examples!

7

kafka-streams-machine-learning-docker-microservice. A Kafka Streams Microservice (using Machine Learning) deployed as a Docker Container

7

camel-infoq. Introduction Demo of Apache Camel (InfoQ article)

6

Apache-Kafka-PipelineAI-Machine-Learning-Infrastructure. Machine Learning Infrastructure leveraging Apache Kafka Ecosystem, PipelineAI, Kubernetes and Docker

5

tensorflow-tfserving-cloud-apache-kafka-streams. Model Inference with Apache Kafka, Kafka Streams and a TensorFlow model deployed to TF-Serving (Google Cloud ML Engine)

3

demo-scene. Scripts and samples to support Confluent Platform talks. May be rough around the edges. For automated tutorials and QA'd code, see https://github.com/confluentinc/quickstart-demos/

2

ksql. Confluent KSQL - Fork of project to enhance it with a User Defined Function (UDF) for Machine Learning.

2

blockchain-demo. A web-based demonstration of blockchain concepts.

2

kafka-streams-python-integration-with-jep. Calling Python Code / Script in Kafka Streams with Jep (TensorFlow Keras Example)

2

Spring-Integration-in-Action. Source code to accompany the book

2

camel-scala-archetype. Scala

1

keras-tensorflow-model-inference-kafka-streams-ksql-dl4j. Keras Tensorflow Model deployed for Inference in Kafka Streams / KSQL microservice via Deeplearning4j

1

tensorflow-kafka-confluent-google-cloud. Deep Learning at Extreme Scale with TensorFlow and Apache Kafka / Confluent on Google Cloud

1

examples. Demo applications and code examples for Confluent Platform and Apache Kafka

1

MyBatis-Scala-In-Samples. MyBatis Scala in Samples is just a set of working MyBatis samples with Scala program language.

1

scalaz-camel. A Scala(z)-based DSL for Apache Camel

1

grails. A powerful web application framework based on the Groovy language

1

ksql-python. A python wrapper for the KSQL REST API.

1

Mule-Webapp-Deployment-Example. Small demo projects

1

techradar. Build your own Technology Radar. Inspired by ThoughtWorks Technology Radar.

1

camel-scala-extra. Few extra extensions to Camel Scala support

1

Spoon-Knife. This repo is for demonstration purposes only. Comments and issues may or may not be responded to.

1

mongo-jackson-mapper. POJO Mapper for MongoDB that uses Jackson

1

gradlePlayApp.

1

hibernate-core. Hibernate's core Object/Relational Mapping functionality

1

musiccrawler. Erlang

1

NFJS-the-Magazine-Testing-Article. Source code for "Mocks and Stubs in Groovy Tests" in December issue of NFJS the Magazine

1

Wolf3D-iOS. Wolfenstein 3D for iOS Source Release

1

jsfunit. Test Framework for JSF Applications, by the JBoss Community

1

camel. Mirror of Apache Camel

1

jersey-on-gae-example. Java

1

h2o-3. Open Source Fast Scalable Machine Learning API For Smarter Applications (Deep Learning, Gradient Boosting, Random Forest, Generalized Linear Modeling (Logistic Regression, Elastic Net), K-Means, PCA, Stacked Ensembles...)

1

AirportWeather. Apache Camel example that can find out the weather at an airport.

1

scalaz. An extension to the core scala library.

1