Skip to content
#

confluent

Here are 125 public repositories matching this topic...

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

  • Updated Apr 6, 2020
  • Jupyter Notebook

The main goal is to play with Kafka Connect and Streams. We have store-api that inserts/updates records in MySQL; Source connectors that monitor inserted/updated records in MySQL and push messages related to those changes to Kafka; Sink connectors that read messages from Kafka and insert documents in ES; Store-streams that listens for messages in Kafka, treats them using Kafka Streams and push new messages back to Kafka.

  • Updated Jul 9, 2020
  • Java

Improve this page

Add a description, image, and links to the confluent 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 confluent topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.