deniskrumko/ksqldb-ui

Free and simple way to interact with ksqlDB using UI

Language: Python - Size: 608 KB - Last synced at: about 18 hours ago - Pushed at: about 19 hours ago - Stars: 2 - Forks: 1

piomin/sample-spring-kafka-datamesh

Several examples of application related to Spring Boot and Kafka components including KafkaConnect, KSQL or Kafka Streams

Language: Java - Size: 71.3 KB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 14 - Forks: 4

ivangfr/springboot-kafka-connect-debezium-ksqldb

Experiment with Kafka, Debezium, and ksqlDB. research-service: Performs MySQL record manipulation. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors and kafka-research-consumer: Listen to Kafka, insert/update Elasticsearch. ksqlDB-Server: Listens to Kafka, performs joins, and pushes new messages to new Kafka topics.

Language: Java - Size: 211 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 84 - Forks: 47

confluentinc/ksql

The database purpose-built for stream processing applications.

Language: Java - Size: 205 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 186 - Forks: 1,042

iobruno/data-engineering-examples

Data Engineering examples for Airflow, Prefect; dbt for BigQuery, Redshift, ClickHouse, Postgres, DuckDB; PySpark for Batch processing; Kafka for Stream processing

Language: Python - Size: 5.02 MB - Last synced at: 4 days ago - Pushed at: 2 months ago - Stars: 65 - Forks: 2

Canner/vulcan-sql

Data API Framework for AI Agents and Data Apps

Language: TypeScript - Size: 70.6 MB - Last synced at: 7 days ago - Pushed at: 10 months ago - Stars: 677 - Forks: 33

tomasfabian/ksqlDB.RestApi.Client-DotNet

ksqlDb.RestApi.Client is a C# LINQ-enabled client API for issuing and consuming ksqlDB push and pull queries and executing statements.

Language: C# - Size: 11.1 MB - Last synced at: 10 days ago - Pushed at: 11 days ago - Stars: 98 - Forks: 25

confluentinc/cp-demo

Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Schema Registry, Security, Schema Linking, and Cluster Linking

Language: Shell - Size: 110 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 47 - Forks: 324

Erachter/ksqldb

A Python wrapper for the KSQLdb REST API

Language: Python - Size: 4.88 KB - Last synced at: 10 days ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 1

confluentinc/demo-scene

Scripts and samples to support Confluent Demos, Talks, and Blogs. Not all of the examples in this repository are kept up to date. For automated tutorials and QA'd code, see https://github.com/confluentinc/tutorials/

Language: Shell - Size: 210 MB - Last synced at: 15 days ago - Pushed at: 21 days ago - Stars: 1,531 - Forks: 902

oslabs-beta/ksqlSuite

Node.js client for ksqlDB

Language: JavaScript - Size: 5.69 MB - Last synced at: 1 day ago - Pushed at: over 1 year ago - Stars: 71 - Forks: 4

DunnBC22/Data_Engineering_Projects

This repository includes data engineering projects using Apache Airflow. I hope to add more projects using different technologies soon!

Language: TSQL - Size: 57.3 MB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 4 - Forks: 0

jcalvarezj/poc-fraud-detection-arch

An example of a Kappa architecture solution for transaction fraud detection

Language: Python - Size: 74.2 KB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 1 - Forks: 0

hpgrahsl/kryptonite-for-kafka

Kryptonite for Kafka is a client-side 🔒 field level 🔓 cryptography library for Apache Kafka® offering a Kafka Connect SMT, ksqlDB UDFs, and a standalone HTTP API service. It's an ! UNOFFICIAL ! community project

Language: Java - Size: 272 KB - Last synced at: 24 days ago - Pushed at: 26 days ago - Stars: 85 - Forks: 7

naamancurtis/ksql-db-rs

A thin wrapper around the KSQL DB REST API to make it more ergonomic to work with in rust.

Language: Rust - Size: 58.6 KB - Last synced at: 29 days ago - Pushed at: 9 months ago - Stars: 7 - Forks: 1

pneff93/stream-processing-playground

Repo to try out different stream processing technologies

Language: Java - Size: 296 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 1

gAmUssA/springone2020-workshop

Developing Event-driven Microservices with Spring Boot, Confluent Cloud, Kotlin, and Java

Language: Shell - Size: 1.61 MB - Last synced at: 17 days ago - Pushed at: over 4 years ago - Stars: 11 - Forks: 8

ably-labs/Realtime-ticket-booking-solution

A simple demo showing how to use Ably and fastAPI to route messages into Kafka for stream processing

Language: Python - Size: 31.3 KB - Last synced at: 17 days ago - Pushed at: over 3 years ago - Stars: 16 - Forks: 4

sheinbergon/ksql-python-ng Fork of bryanyang0528/ksql-python

Pythonic KSQL REST API - Next Gen.

Language: Python - Size: 321 KB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 3 - Forks: 1

Charlie5DH/Full-Stack-Kafka-Stack

For recreational use. Just a playground of Kafka+Spark+MQTT+KSQLDB+others

Language: Python - Size: 5.06 MB - Last synced at: about 2 months ago - Pushed at: about 2 years ago - Stars: 8 - Forks: 1

babanomania/etl-streaming

This project demonstrates a modern ETL (Extract, Transform, Load) streaming pipeline using various open-source technologies.

Language: Python - Size: 25.4 KB - Last synced at: 29 days ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

alfakini/workshop-codecon-kafka

Exemplos do workshop realizado na codecon.dev sobre arquitetura event-driven com Apache Kafka.

Language: Java - Size: 37.1 KB - Last synced at: 1 day ago - Pushed at: over 4 years ago - Stars: 12 - Forks: 4

hifly81/saga-pattern-demo

Saga Pattern Showcase - Choreography implementation with quarkus, debezium, elastic search - Orchestrator with ksqlDB

Language: Java - Size: 1.59 MB - Last synced at: 14 days ago - Pushed at: over 1 year ago - Stars: 40 - Forks: 17

selcuksert/task-manager

Basic task management application based on event driven architecture paradigm

Language: JavaScript - Size: 16.9 MB - Last synced at: 26 days ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 0

lyteabovenyte/stream-processing-application

building multi-container stream processing and stateful event-streaming application using Kafka platform ,Kafka Streams, KTable, Processor API and KsqlDB

Language: Java - Size: 389 KB - Last synced at: about 1 month ago - Pushed at: 5 months ago - Stars: 0 - Forks: 0

oslabs-beta/kafkaESK

An event-driven monitoring tool that can consume messages from Apache Kafka clusters and display the aggregated data on a dashboard for analysis and maintenance.

Language: JavaScript - Size: 7.64 MB - Last synced at: 18 days ago - Pushed at: about 4 years ago - Stars: 77 - Forks: 4

confluentinc/learn-kafka-courses

Learn the basics of Apache Kafka® from leaders in the Kafka community with these video courses covering the Kafka ecosystem and hands-on exercises.

Language: Shell - Size: 41 MB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 17 - Forks: 77

riferrei/is-using-kop-a-good-idea

Is using KoP (Kafka-On-Pulsar) a good idea? Use the scenarios implemented in this repository to check whether Pulsar with KoP enabled is a good fit for your most common Kafka workloads.

Language: Java - Size: 898 KB - Last synced at: 7 days ago - Pushed at: over 2 years ago - Stars: 10 - Forks: 2

confluentinc/kafka-tutorials

Tutorials and Recipes for Apache Kafka

Language: Java - Size: 21.1 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 14 - Forks: 89

mmolimar/ksql-jdbc-driver

JDBC driver for Apache Kafka

Language: Scala - Size: 288 KB - Last synced at: 5 months ago - Pushed at: about 3 years ago - Stars: 88 - Forks: 19

shinichi-hashitani/splunk-confluent-sandbox

ネットワーク機器のログをSplunkのUniversal Forwarderを利用してConfluentに転送し、ストリーム処理後にSplunkのHECに転送するサンドボックス環境。

Language: Shell - Size: 1.58 MB - Last synced at: 8 months ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0

tamboto2000/ksqldbx

ksqlDB client in Go

Language: Go - Size: 158 KB - Last synced at: 8 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

dgnyshn/ksql-cli

A simple prompt for ksql

Language: Go - Size: 3.77 MB - Last synced at: 9 months ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

LapoElisacci/Ksql

ksqlDB Client for Ruby

Language: Ruby - Size: 117 KB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 25 - Forks: 3

pneff93/Think-of-ksqlDB-before-using-KafkaStreams

Repository about data aggregation with different frameworks in different environments

Language: Java - Size: 149 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 3 - Forks: 1

sauljabin/kafka-sandbox

Kafka Sandbox helps you to deploy a kafka sandbox locally

Language: Java - Size: 110 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 11 - Forks: 3

confluentinc/demo-stream-designer

Current 2022 Confluent Keynote Demo covering Stream Designer, Stream Catalog, and Stream Sharing.

Language: Python - Size: 29.7 MB - Last synced at: 4 months ago - Pushed at: 11 months ago - Stars: 11 - Forks: 4

confluentinc/demo-database-modernization

This demo shows how to stream data to cloud databases with Confluent. It includes fully-managed connectors (Oracle CDC, RabbitMQ, MongoDB Atlas), ksqlDB/Flink SQL as stream processing engine.

Language: HCL - Size: 10.3 MB - Last synced at: 10 months ago - Pushed at: 11 months ago - Stars: 4 - Forks: 0

confluentinc/demo-realtime-data-warehousing

Streaming data pipelines for real-time data warehousing. Includes fully managed connectors (PostgreSQL CDC, Snowflake).

Language: HCL - Size: 10.7 MB - Last synced at: 10 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

confluentinc/demo-change-data-capture

This demo shows how to capture data changes from relational databases (Oracle and PostgreSQL) and stream them to Confluent Cloud, use ksqlDB for real-time stream processing, send enriched data to cloud data warehouses (Snowflake and Amazon Redshift).

Language: HCL - Size: 8.57 MB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 10 - Forks: 2

agnivchtj/youtube_watcher

Building a streaming Kafka application to push live notifications for updates to views, likes, favorites and comments on Youtube videos.

Language: Python - Size: 8.85 MB - Last synced at: about 1 month ago - Pushed at: 12 months ago - Stars: 0 - Forks: 0

rbiedrawa/kafka-monitoring

The goal of this project is to demonstrate different approaches how to monitor Apache Kafka ecosystem.

Language: Java - Size: 5.18 MB - Last synced at: about 1 month ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 1

ttimot24/mndwrk-webinar-kafka-demo

MNDWRK - Apache Kafka Webinar

Language: Java - Size: 4.87 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 4 - Forks: 1

0xSumitBanik/ksqldb-eth-avg-gas-estimate

This repository contains a KSQLDB setup connection that streams the average ETH Gas Estimate using the Ethereum Gas Estimate API as source data.

Language: Python - Size: 9.77 KB - Last synced at: 12 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

osodevops/kafka-gitops-examples

A Kafka / Confluent GitOps workflow example for multi-env deployments with Flux, Kustomize, Helm and Confluent For Kubernetes (CFK) Operator

Language: Makefile - Size: 184 KB - Last synced at: 12 months ago - Pushed at: almost 3 years ago - Stars: 7 - Forks: 11

daniellavoie/ksqldb-java-client

Non-Blocking Reactive Java Client for ksqlDB

Language: Java - Size: 86.9 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 9 - Forks: 3

padogrid/bundle-geode-1-docker-debezium_ksqldb_confluent

This bundle integrates Geode with Debezium and Confluent ksqlDB for ingesting initial data and CDC records from MySQL into Kafka and Geode via a Kafka sink connector included in the padogrid distribution.

Language: Shell - Size: 28.1 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

Tiao553/bigdata-k8s-kafka

In this repository i will allocate my architecture project, all on a kubernetes cluster.

Language: Mustache - Size: 12.8 MB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 1 - Forks: 0

aliramirez369/kafka-full-stack

Cluster and brokers configuration in Apache kafka with Metric Visualization using JMX Exporter Agent, Connection and monitoring of Prometheus, Grafana, Conduktor, kafka Connect, kafka-schema-registry, ksqlDB,kafka REST Proxy, PostgreSql, and PgAdmin 4 in Docker Containers.

Size: 1.89 MB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0

WiljamiT/google-cloud-data-eng

Collect & stream data, notify user on Telegram

Language: HTML - Size: 17.2 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

nkonev/ksql-example

Language: Java - Size: 1.86 MB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

seanmorris/ksqlc

The Asynchronous PHP KSQL Connector

Language: PHP - Size: 895 KB - Last synced at: 15 days ago - Pushed at: about 1 year ago - Stars: 12 - Forks: 4

kwonghung-YIP/publish-msg-with-kafka-connect-mqtt-nextjs

Message publishing with Kafka Connect, MQTT(HiveMQ) and Nextjs

Language: TypeScript - Size: 11.2 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

Marx-wrld/Kafka-PythonDataStream

Data streaming with Python and Apache Kafka

Language: Python - Size: 83 KB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

Dwijad/Ksql-Docker

Ksql Docker

Language: Shell - Size: 164 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

thunchanokbow/Cinema-Data-Streaming-with-Kafka

change data capture (CDC) to ingest binlogs from the source database, process them, and write them to the target database correctly, completely, and instantly in real time. using docker-compose,Kafka connectors (debezium, jdbc sink), compute engine, cloud sql, database mysql, confluent.

Language: HTML - Size: 101 MB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

josuedallagnese/kafka-ksql-logs

Kafka + KSQL DB + Request Logging

Language: C# - Size: 415 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

enots227/kafka-sink-connector-using-ksql

Practice project setting up Kafka and a simple Kafka Postgres sink connector using KSQL.

Language: Shell - Size: 10.7 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0

josuedallagnese/kafka-ksql-sample

Kafka + ksqldb

Language: C# - Size: 8.79 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

mwn-san/Confluent

Encompassed here are pivotal insights on Kafka, poised to empower and greatly benefit a multitude, fostering harmony among fellow MWN aficionados

Language: Shell - Size: 65.4 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

QuantumFuturist/datastack-kafka

This repository is a comprehensive guide and toolkit for anyone looking to understand and implement data streaming solutions using Apache Kafka.

Size: 9.77 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

kattlo/kattlo-cli 📦

Kattlo CLI Project

Language: Java - Size: 1.16 MB - Last synced at: 3 months ago - Pushed at: about 3 years ago - Stars: 66 - Forks: 4

hpgrahsl/current22-k4k-demo

This repository hosts the live demo scenario shown during my Current22 talk about 'Client-Side Field Level Cryptography for Streaming Data Pipelines'

Language: Shell - Size: 68.5 MB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

trannhatnguyen2/yotube-analytics-streams

An end-to-end data engineering pipeline that fetches real-time YouTube analytics and streams them through Kafka for processing with ksqlDB. The processed analytics data is then sent to Telegram for real-time notifications.

Language: HTML - Size: 8.66 MB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

amogh18t/Kafka-YoutubeWatcher

Streams out live data of Youtube videos by Kafka by Confluent Cloud via ksqlDB , and sends custom notifications by Telegram

Language: Python - Size: 12.7 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

aliramirez369/kafka-stack

Configuration of Cluster and Brokers in Apache Kafka, Kafka Connect, Kafka Schema Registry, ksqlDB Server, PostgreSQL and pgAdmin in Docker containers.

Size: 601 KB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

kaiwaehner/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

Language: Jupyter Notebook - Size: 24.9 MB - Last synced at: over 1 year ago - Pushed at: over 4 years ago - Stars: 373 - Forks: 138

quantiaconsulting/continuous-analytics-examples

A collection of examples of continuous analytics.

Language: Jupyter Notebook - Size: 180 MB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 16 - Forks: 8

matewz/Kafka-ecosystem

Complete Kafka environment with Producer and Consumer

Language: Jupyter Notebook - Size: 163 KB - Last synced at: over 1 year ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

jagatsingh/mastering-kafka-streams-and-ksqldb Fork of mitch-seymour/mastering-kafka-streams-and-ksqldb

Code repository for the Mastering Kafka Streams and ksqlDB book

Language: Java - Size: 541 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

eshepelyuk/pykli 📦

Interactive ksqlDB command line client with autocompletion and syntax highlighting written in Python

Language: Python - Size: 104 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 7 - Forks: 0

MohammadRhz/ksql-udf-first-day-of-the-week

Get the date of the first day of the week when the date you want is in the range of that week

Language: Java - Size: 74.2 KB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

gordonmurray/terraform_rds_debezium_kafka_ksqldb

Create an environment on AWS using Terraform and Ansible to show a Change Data Capture (CDC) process working end to end from MariaDB on RDS to Redis on Elasticache, using Debezium and ksqlDB.

Language: HCL - Size: 11 MB - Last synced at: 1 day ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

metaheed/kolle

Business model representation automation

Language: Shell - Size: 154 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 7 - Forks: 1

eugene-khyst/ksqldb-event-souring 📦

Kafka is not for event sourcing, isn't it? Kafka alone is not an event store, but Kafka and ksqlDB together allow building full-featured event stores. This repository provides a sample of event sourced system that uses Kafka and ksqlDB as event store.

Language: Java - Size: 2.27 MB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 61 - Forks: 13

berthayes/cp-zeek

Analyze Zeek IDS data with ksqlDB running on Confluent Platform via Docker on your laptop. Or spin up an arbitrary number of AWS hosts, each running Confluent Platform and ksqlDB for use in an instructor-led workshop.

Language: Python - Size: 169 MB - Last synced at: over 1 year ago - Pushed at: over 3 years ago - Stars: 10 - Forks: 5

vhtnguyen/Kafka_Youtube-watcher

An app to keep track of Youtube videos and sends the notification to a Telegram bot to inform you if anyone comments on those

Language: Python - Size: 561 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 0

hfhoffman1144/smartphone_sensor_stream2

Stream smartphone sensor data with FastAPI, Kafka, ksqlDB, and Docker.

Language: Python - Size: 39.7 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 0

maxng07/ksqlDB

Learnings on ksqlDB

Size: 92.8 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

twosom/mastering-kafka-streams

Practice for Mastering Kafka Streams and ksqlDB

Language: Java - Size: 161 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

hpgrahsl/ksqldb-datetime-functions

Custom 🚀 ksqlDB 🚀 UDF library for convenient 📆 date & time 🕚 handling and processing

Language: Java - Size: 64.5 KB - Last synced at: about 2 months ago - Pushed at: over 4 years ago - Stars: 4 - Forks: 0

Stefen-Taime/Kafka-pipeline

In the following post, we will learn how to build a data pipeline using a combination of open-source software (OSS), including Debezium, Apache Kafka, Kafka Connect.

Language: Shell - Size: 2.65 MB - Last synced at: 10 days ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 3

lafabigdatamg/edc-mod2-k8s-exercise-igti

TRABALHO PRÁTICO DO MÓDULO 2 DO BOOTCAMP ENGENHARIA DE DADOS CLOUD IGTI 2022

Language: Java - Size: 105 MB - Last synced at: almost 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 1

zacharydhamilton/jackpot

Online slot machine using Confluent Cloud and ksqlDB.

Language: Java - Size: 22.3 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 1

wscardua/kafka-python-grafana-influx

Utilização do kafka como plataforma de stream de dados distribuído para coleta de cotações de bitcoins e distribuição da informação via dashboard

Size: 10.5 MB - Last synced at: almost 2 years ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0

ThinhPV/real-time-streaming-etl-pipeline-with-kafka

Build a Real-Time Streaming ETL Pipeline with Apache Kafka, Kafka Connect, and ksqlDB

Language: TSQL - Size: 271 KB - Last synced at: almost 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

snigdhasjg/kafka-events-demo

Processing database events and sink it to different data storage

Language: Java - Size: 148 KB - Last synced at: 12 months ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

sinhaGuild/micro-lh

Language: TSQL - Size: 1.95 KB - Last synced at: 9 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

hpgrahsl/ksqldb-emoji-functions

The missing EMOJI 😍 handling functions for 🚀 ksqlDB 🚀

Language: Java - Size: 20.5 KB - Last synced at: about 2 months ago - Pushed at: about 5 years ago - Stars: 1 - Forks: 0

sauljabin/kinetik

ksqlDB UI

Language: TypeScript - Size: 1.31 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

mehdihasan/real-time-fraud-analysis

Real time fraud analysis using Kafka Streams

Language: Python - Size: 38.6 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

nikeshnaik/ksqlDB_stream_analytics

Using Kafka Stack for Stream Processing. KSQLDB, Kafka connect, Schema Registry, ksql python client

Language: Python - Size: 2.85 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

PiotrMichalowski96/stock-streaming-service

Introduction to ksqlDB used with Spring Boot and Apache Camel

Language: Java - Size: 78.1 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

aweagel/ksql_workshop

Let's Learn ksqlDB

Language: Dockerfile - Size: 926 KB - Last synced at: 7 days ago - Pushed at: almost 5 years ago - Stars: 23 - Forks: 7

thmeitz/ksqldb-migrate

Migration tool for ksqlDB

Language: Go - Size: 7.44 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 3 - Forks: 1

streamthoughts/demo-twitter-ksqldb-clickhouse

Demonstration Project : Fast Data Analytic platform with Clickhouse, Apache Kafka and ksqlDB

Language: Java - Size: 9.77 KB - Last synced at: about 2 years ago - Pushed at: almost 5 years ago - Stars: 14 - Forks: 11

mrmorais/racing-cars-demo

Online Interactive Game for Kafka/kSQL Demo

Language: Java - Size: 248 KB - Last synced at: 20 days ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

zeenfts/ksqldb-stream-kafka

Stream Processing Data from PostgresSQL using ksqlDB on Apache Kafka.

Language: SQL - Size: 601 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

orange-cloudfoundry/orange-ksql-enriched

Image based on confluentinc/ksqldb-cli:0.28.2 and add some tools to it.

Language: Dockerfile - Size: 17.6 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

akbari4yaseen/ksqldb-postgres-kafka-connect

quickly set up a data pipeline and move data from KSQL/PostgresSQL to PostgreSQL

Language: Dockerfile - Size: 3.91 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0