Skip to content
#

ksqldb

Here are 59 public repositories matching this topic...

j4freeman
j4freeman commented Feb 14, 2022

I have a use case where I need to create a new stream containing the bearing between two consecutive points in a pre-existing lat/lon stream. Normally bearing would be available in a standard lib but in a pinch can easily be implemented through sin, cos, and atan2 funcs, none of which are currently available in ksql.

Basic trig functions have a range of use cases in geometric and geographic co

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 Nov 5, 2020
  • Jupyter Notebook

The goal of this project is to play with Kafka, Debezium and ksqlDB. For this, we have: research-service that inserts/updates/deletes records in MySQL; Source Connectors that monitor change of records in MySQL and push messages related to those changes to Kafka; Sink Connectors and kafka-research-consumer that listen messages from Kafka and insert/update documents in Elasticsearch; finally, ksqlDB-Server that listens to some topics in Kafka, does some joins and pushes new messages to new topics in Kafka.

  • Updated Feb 25, 2022
  • Java

Kafka Sandbox helps you to deploy a kafka sandbox locally. It intends to be a simple way to get started with kafka and help you on your learning path. It provides you with a wide variety of tools from the kafka ecosystem and a simple way to run them all. It also includes a set of tools and tips to make it easier for you to use kafka. It does not include security since it is not a production system

  • Updated Oct 16, 2021
  • Java

Improve this page

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

Learn more