GitHub topics: kafka-connect
ilssaf/data-platform-deployer
CLI tool for automatic data platform deployment
Language: Python - Size: 893 KB - Last synced at: about 8 hours ago - Pushed at: about 8 hours ago - Stars: 1 - Forks: 0
debezium/debezium
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Language: Java - Size: 58.5 MB - Last synced at: about 12 hours ago - Pushed at: about 14 hours ago - Stars: 11,354 - Forks: 2,647
confluentinc/cp-ansible
Ansible playbooks for the Confluent Platform
Language: Jinja - Size: 64.6 MB - Last synced at: about 15 hours ago - Pushed at: about 15 hours ago - Stars: 53 - Forks: 408
Aiven-Open/klaw
Klaw, the latest OS tool by Aiven, helps enterprises cope with Apache Kafka(r) topics, schema registry and connectors governance by introducing roles/authorizations to users of various teams of an org.
Language: Java - Size: 48.7 MB - Last synced at: about 20 hours ago - Pushed at: about 21 hours ago - Stars: 166 - Forks: 67
strimzi/strimzi.github.io
Strimzi web site project
Language: HTML - Size: 118 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 32 - Forks: 73
littlehorse-enterprises/lh-kafka-connect
LittleHorse Connectors for Kafka Connect
Language: Java - Size: 159 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 4 - Forks: 1
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, Flink UDFs, and a standalone HTTP API service. It's an ! UNOFFICIAL ! community project
Language: Java - Size: 272 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 85 - Forks: 7
confluentinc/kafka-connect-elasticsearch
Kafka Connect Elasticsearch connector
Language: Java - Size: 3.22 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 24 - Forks: 438
farel46/spring-cloud-stream-kafka
Some working examples of Spring Cloud Stream for Kafka
Language: Java - Size: 18.6 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 0 - Forks: 0
Aiven-Open/transforms-for-apache-kafka-connect
Aiven's collection of Single Message Transformations (SMTs) for Apache Kafka Connect
Language: Java - Size: 478 KB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 77 - Forks: 26
provectus/kafka-ui
Open-Source Web UI for Apache Kafka Management
Language: Java - Size: 29 MB - Last synced at: 5 days ago - Pushed at: 9 months ago - Stars: 10,684 - Forks: 1,271
aws/eventbridge-kafka-connector
Kafka sink connector for Amazon EventBridge to send events (records) from Kafka topic(s) to the specified EventBridge event bus
Language: Java - Size: 1.15 MB - Last synced at: 5 days ago - Pushed at: 8 days ago - Stars: 71 - Forks: 6
snowflakedb/snowflake-kafka-connector
Snowflake Kafka Connector (Sink Connector)
Language: Java - Size: 140 MB - Last synced at: 5 days ago - Pushed at: 6 days ago - Stars: 152 - Forks: 103
strimzi/strimzi-kafka-operator
Apache Kafka® running on Kubernetes
Language: Java - Size: 91.9 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 5,214 - Forks: 1,358
RADAR-base/RADAR-REST-Connector
A Kafka Source connector to receive data from REST APIs and publish them to Kafka. It has an extended version to support FitBit APIs.
Language: Java - Size: 2.44 MB - Last synced at: 1 day ago - Pushed at: 7 days ago - Stars: 5 - Forks: 5
vdesabou/kafka-docker-playground
🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷♂️ Easily build examples or reproduction models
Language: Shell - Size: 163 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 726 - Forks: 216
michelin/ns4kafka
Namespaces for Apache Kafka.
Language: Java - Size: 2.95 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 81 - Forks: 13
Altinity/clickhouse-sink-connector
Replicate data from MySQL, Postgres and MongoDB to ClickHouse®
Language: Python - Size: 257 MB - Last synced at: 3 days ago - Pushed at: 7 days ago - Stars: 255 - Forks: 60
confluentinc/kafka-connect-storage-cloud
Kafka Connect suite of connectors for Cloud storage (Amazon S3)
Language: Java - Size: 3.97 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 22 - Forks: 335
confluentinc/ksql
The database purpose-built for stream processing applications.
Language: Java - Size: 206 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 189 - Forks: 1,042
apache/doris-kafka-connector
Kafka Connector for Apache Doris
Language: Java - Size: 363 KB - Last synced at: 3 days ago - Pushed at: 7 days ago - Stars: 19 - Forks: 13
confluentinc/kafka-connect-storage-common
Shared software among connectors that target distributed filesystems and cloud storage.
Language: Java - Size: 4.41 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 7 - Forks: 155
Aiven-Open/cloud-storage-connectors-for-apache-kafka
Repository containing Cloud Storage Connectors for Apache Kafka®
Language: Java - Size: 3.43 MB - Last synced at: 7 days ago - Pushed at: about 1 month ago - Stars: 27 - Forks: 19
ibm-messaging/kafka-connect-mq-sink
This repository contains a Kafka Connect sink connector for copying data from Apache Kafka into IBM MQ.
Language: Java - Size: 222 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 39 - Forks: 44
ibm-messaging/kafka-connect-mq-source
This repository contains a Kafka Connect source connector for copying data from IBM MQ into Apache Kafka.
Language: Java - Size: 288 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 99 - Forks: 84
linkedin/Hoptimator
Multi-hop declarative data pipelines
Language: Java - Size: 810 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 115 - Forks: 11
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: 60.5 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 4 - Forks: 0
kafbat/kafka-ui
Open-Source Web UI for managing Apache Kafka clusters
Language: Java - Size: 34.7 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 1,030 - Forks: 136
euiyounghwang/Prometheus-monitoring-exporter
Prometheus-monitoring-exporter
Language: Python - Size: 256 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 0 - Forks: 0
uuhnaut69/online-merchant-monitor
An example about online merchant monitor based on Kafka, Kafka Stream, Kafka Connect,KSQL
Language: Java - Size: 376 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 4 - Forks: 1
uuhnaut69/saga-pattern-microservices
Demo saga pattern, outbox pattern using Spring Boot, Debezium, Kafka, Kafka Connect
Language: Java - Size: 410 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 116 - Forks: 35
ClickHouse/clickhouse-kafka-connect
ClickHouse Kafka Connector
Language: Java - Size: 2.89 MB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 175 - Forks: 48
ably/kafka-connect-ably
Kafka Connector for publishing data from Kafka to Ably
Language: Java - Size: 800 KB - Last synced at: 6 days ago - Pushed at: 10 months ago - Stars: 13 - Forks: 7
ivangfr/springboot-kafka-connect-jdbc-streams
Project goal: Explore Kafka, Kafka Connect, and Kafka Streams. Components: store-api: Inserts/updates MySQL records. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors: Listen to Kafka, insert/update Elasticsearch docs. store-streams: Listens to Kafka, processes with Kafka Streams, pushes new messages to Kafka.
Language: Java - Size: 283 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 113 - Forks: 72
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: 12 days ago - Pushed at: 12 days ago - Stars: 84 - Forks: 47
apecloud/ape-dts
ApeCloud's Data Transfer Suite, written in Rust. Provides ultra-fast data replication between MySQL, PostgreSQL, Redis, MongoDB, Kafka and ClickHouse, ideal for disaster recovery (DR) and migration scenarios.
Language: Rust - Size: 65.3 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 428 - Forks: 58
Eddie4k-code/kafka-connect-deduplicator
A Kafka Connect Single Message Transformation that will avoid duplicate messages being delivered.
Language: Java - Size: 45.9 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 1 - Forks: 0
jonathanmdr/resilience-http-client
Sample project to explain about resilient patterns for integration distributed services
Language: Java - Size: 53.5 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 5 - Forks: 0
Aiven-Open/klaw-docs
Documentation site for Klaw, our Open Source Apache Kafka® governance toolkit.
Language: JavaScript - Size: 123 MB - Last synced at: 7 days ago - Pushed at: 14 days ago - Stars: 5 - Forks: 8
microsoft/kafka-connect-cosmosdb
Kafka Connect connectors for Azure Cosmos DB
Language: Java - Size: 5.31 MB - Last synced at: 6 days ago - Pushed at: 2 months ago - Stars: 53 - Forks: 54
lensesio/kafka-connect-ui
Web tool for Kafka Connect |
Language: JavaScript - Size: 1.17 MB - Last synced at: 12 days ago - Pushed at: over 1 year ago - Stars: 509 - Forks: 132
averemee-si/oracdc
Oracle database CDC (Change Data Capture)
Language: Java - Size: 6.5 MB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 118 - Forks: 41
Aiven-Open/gcs-connector-for-apache-kafka 📦
Aiven's GCS Sink Connector for Apache Kafka®
Language: Java - Size: 1.02 MB - Last synced at: 7 days ago - Pushed at: 8 months ago - Stars: 71 - Forks: 39
vinted/kafka-connect-vespa
Kafka Connect Vespa sink connector
Language: Java - Size: 74.2 KB - Last synced at: 18 days ago - Pushed at: 19 days ago - Stars: 14 - Forks: 1
darklore/kafka-connect-cli
Language: Go - Size: 182 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 1 - Forks: 0
selcuksert/task-manager
Basic task management application based on event driven architecture paradigm
Language: JavaScript - Size: 16.9 MB - Last synced at: 6 days ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 0
Willena/connect-influxdb-sink
Kafka connect influxdb sink
Language: Java - Size: 216 KB - Last synced at: 23 days ago - Pushed at: 23 days ago - Stars: 0 - Forks: 0
mongodb/mongo-kafka
MongoDB Kafka Connector
Language: Java - Size: 1.76 MB - Last synced at: 22 days ago - Pushed at: 24 days ago - Stars: 359 - Forks: 257
bakdata/kpops
Deploy Kafka pipelines to Kubernetes
Language: Python - Size: 15.6 MB - Last synced at: 10 days ago - Pushed at: 25 days ago - Stars: 14 - Forks: 3
lensesio/stream-reactor
A collection of open source Apache 2.0 Kafka Connector maintained by Lenses.io.
Language: Scala - Size: 20.6 MB - Last synced at: 25 days ago - Pushed at: about 1 month ago - Stars: 1,022 - Forks: 371
compose-x/kafka-connect-api
Python API to interact with Kafka Connect cluster
Language: Python - Size: 236 KB - Last synced at: 9 days ago - Pushed at: 26 days ago - Stars: 1 - Forks: 2
JesuFemi-O/kafka-spark
exploring CDC with Debezium, Kafka Connect, Spark structured streaming and Lakehouses
Language: Dockerfile - Size: 8.79 KB - Last synced at: 22 days ago - Pushed at: 26 days ago - Stars: 0 - Forks: 0
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: 25 days ago - Pushed at: about 1 month ago - Stars: 1,531 - Forks: 902
uts58/kafka-connect-mqtt-file
A Java module for Kafka Connect, supporting both Source and Sink functionalities
Language: Java - Size: 60.5 KB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 0 - Forks: 0
JohnPreston/kafka-connect-watcher
Kafka Connect Watcher
Language: Python - Size: 213 KB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 3 - Forks: 4
salesforce/mirus
Mirus is a cross data-center data replication tool for Apache Kafka
Language: Java - Size: 269 KB - Last synced at: 23 days ago - Pushed at: about 2 months ago - Stars: 204 - Forks: 43
scylladb/scylla-cdc-source-connector
A Kafka source connector capturing Scylla CDC changes
Language: Java - Size: 1.05 MB - Last synced at: 26 days ago - Pushed at: 28 days ago - Stars: 51 - Forks: 20
masesgroup/KNet
KNet is a comprehensive .NET suite for Apache Kafka™ providing all features: Producer, Consumer, Admin, Streams, Connect, backends (ZooKeeper and Kafka)
Language: C# - Size: 134 MB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 45 - Forks: 6
scholzj/echo-sink
Kafka Connect plugin which logs messages into log
Language: Java - Size: 25.4 KB - Last synced at: 22 days ago - Pushed at: 28 days ago - Stars: 6 - Forks: 1
izemskov/Code-Lab
Code Lab – Java Projects & Experiments
Language: Java - Size: 2.39 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 6 - Forks: 0
upstash/kafka-connectors 📦
Kafka Connect with Upstash Kafka®
Language: Shell - Size: 223 MB - Last synced at: 5 days ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0
jaehyeon-kim/kafka-pocs
Apache Kafka and Related Projects
Language: Shell - Size: 63.6 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 30 - Forks: 11
Trendyol/go-dcp-kafka
The Go implementation of the Couchbase to Kafka with DCP.
Language: Go - Size: 1.92 MB - Last synced at: 5 days ago - Pushed at: about 2 months ago - Stars: 69 - Forks: 18
rodrigo-molina/kafka-connect-s3-irsa
AWS IAM Roles for Service Accounts (IRSA) for Kafka Connect Confluent S3 Sink
Language: Java - Size: 48.8 KB - Last synced at: 25 days ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
sanjuthomas/kafka-connect-marklogic
Kafka Sink Connect MarkLogic
Language: Java - Size: 8.86 MB - Last synced at: 2 days ago - Pushed at: 10 months ago - Stars: 19 - Forks: 4
Aiven-Open/jdbc-connector-for-apache-kafka
Aiven's JDBC Sink and Source Connectors for Apache Kafka®
Language: Java - Size: 13.1 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 102 - Forks: 57
LuanC14/ms-courses-integration
A microservice that performs CRUD on a PostgreSQL courses table, caches data in Redis for faster queries, and integrates with Kafka, Kafka Connect, and KSQL to replicate created/updated data in Oracle DB.
Language: Java - Size: 28.3 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
streamthoughts/kafka-connect-file-pulse
🔗 A multipurpose Kafka Connect connector that makes it easy to parse, transform and stream any file, in any format, into Apache Kafka
Language: Java - Size: 16.5 MB - Last synced at: 2 days ago - Pushed at: 4 days ago - Stars: 327 - Forks: 69
osodevops/CCAAK-Exam-Questions
Confluent Kafka questions to practice for CCAAK
Size: 32.2 KB - Last synced at: 2 days ago - Pushed at: 2 months ago - Stars: 12 - Forks: 2
dkadetov/strimzi-kafka-connect
Helm Chart for Apache Kafka Connect inspired by Strimzi
Language: Shell - Size: 375 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 3 - Forks: 0
Anant/Cassandra.Realtime
Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink
Language: Scala - Size: 575 MB - Last synced at: 21 days ago - Pushed at: almost 3 years ago - Stars: 31 - Forks: 24
itadventurer/kafka-backup
Backup and Restore for Apache Kafka
Language: Java - Size: 2.71 MB - Last synced at: about 1 month ago - Pushed at: 5 months ago - Stars: 168 - Forks: 48
Aiven-Open/elasticsearch-connector-for-apache-kafka
Apache Kafka Connect sink connector for Elasticsearch
Language: Java - Size: 1.1 MB - Last synced at: 7 days ago - Pushed at: 2 months ago - Stars: 8 - Forks: 4
EladLeev/KeyToField-smt
A Kafka Connect Single Message Transform (SMT) that enables you to append the record key to the value as a named field
Language: Java - Size: 75.2 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 19 - Forks: 3
redhat-italy/rht-summit2019-saga
Saga Pattern implementations
Language: Java - Size: 568 KB - Last synced at: 24 days ago - Pushed at: about 1 year ago - Stars: 25 - Forks: 14
AymenDaoudi/Electric-Vehicle-Charging-Simulator
Simulation, Ingestion and ETL-ing data of millions of EV charging sessions by thousands of EVs in thousands of stations around the world.
Language: Python - Size: 9.65 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
Aiven-Open/http-connector-for-apache-kafka
Apache Kafka Connect sink connector for HTTP
Language: Java - Size: 712 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 106 - Forks: 50
san089/Optimizing-Public-Transportation
A real-time event pipeline around Kafka Ecosystem for Chicago Transit Authority.
Language: Python - Size: 496 KB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 30 - Forks: 14
LangStream/langstream
LangStream. Event-Driven Developer Platform for Building and Running LLM AI Apps. Powered by Kubernetes and Kafka.
Language: Java - Size: 118 MB - Last synced at: 23 days ago - Pushed at: 10 months ago - Stars: 414 - Forks: 33
rbiedrawa/cdc-postgres
Change Data Capture with Debezium & PostgreSQL. This repository contains the demo Docker Compose file for setting up and running the whole CDC infrastructure (Kafka Connect, Debezium, PostgreSQL etc.)
Language: Shell - Size: 487 KB - Last synced at: about 1 month ago - Pushed at: over 3 years ago - Stars: 9 - Forks: 1
an0r0c/kafka-connect-transform-tojsonstring
transform-to-json-string is a Single Message Transformation (SMT) for Apache Kafka® Connect to convert a given Connect Record to a single JSON String. It's an UNOFFICIAL community project.
Language: Java - Size: 87.9 KB - Last synced at: 1 day ago - Pushed at: over 1 year ago - Stars: 36 - Forks: 16
sergio11/iot_event_streaming_architecture
🌐📈 Unlock IoT potential with this Event Streaming Architecture: Apache Kafka and MQTT power real-time data handling. Visualize, analyze, and scale effortlessly. 🚀💻📊
Language: Java - Size: 27.5 MB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 20 - Forks: 19
build-on-aws/prioritizing-event-processing-with-apache-kafka
Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.
Language: Java - Size: 585 KB - Last synced at: about 1 month ago - Pushed at: 6 months ago - Stars: 28 - Forks: 8
build-on-aws/building-apache-kafka-connectors
Sample code that shows the important aspects of developing custom connectors for Kafka Connect. It provides the resources for building, deploying, and running the code on-premises using Docker, as well as running the code in the cloud.
Language: Java - Size: 57.6 KB - Last synced at: 25 days ago - Pushed at: 11 months ago - Stars: 54 - Forks: 14
chetanghadiya007/kafka_zookeeper_nodejs
Scalable Application Using Kafka, Zookeeper, and Node.js
Language: JavaScript - Size: 2.93 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0
jcustenborder/connect-utils
Utility project for working with Kafka Connect.
Language: Java - Size: 963 KB - Last synced at: 25 days ago - Pushed at: 9 months ago - Stars: 34 - Forks: 27
mtpatter/postgres-kafka-demo
Fully reproducible, Dockerized, step-by-step, demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres. Detailed blog post published on Medium.
Language: Dockerfile - Size: 706 KB - Last synced at: 1 day ago - Pushed at: over 3 years ago - Stars: 153 - Forks: 64
rkudryashov/event-driven-architecture
Event-driven architecture (Transactional outbox, Inbox, and Saga patterns) on the modern stack of Java technologies.
Language: Kotlin - Size: 12.8 MB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 44 - Forks: 10
jcustenborder/kafka-connect-solr
Kafka Connect connector for writing to Solr.
Language: Java - Size: 167 KB - Last synced at: about 1 month ago - Pushed at: about 2 years ago - Stars: 44 - Forks: 28
Aiven-Open/s3-connector-for-apache-kafka 📦
Aiven's S3 Sink Connector for Apache Kafka®
Language: Java - Size: 975 KB - Last synced at: 7 days ago - Pushed at: 8 months ago - Stars: 69 - Forks: 27
jcustenborder/kafka-connect-parent
Parent pom for Kafka Connect Connectors.
Size: 58.6 KB - Last synced at: about 2 months ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 16
ddd-by-examples/all-things-cqrs
Comprehensive guide to a couple of possible ways of synchronizing two states with Spring tools. Synchronization is shown by separating command and queries in a simple CQRS application.
Language: Java - Size: 3.55 MB - Last synced at: about 1 month ago - Pushed at: about 6 years ago - Stars: 603 - Forks: 148
jcustenborder/kafka-connect-transform-common
Common Transforms for Kafka Connect.
Language: Java - Size: 169 KB - Last synced at: 27 days ago - Pushed at: 9 months ago - Stars: 157 - Forks: 66
lawrencemq/snowflake-kafka-jdbc-connector
Kafka to Snowflake JDBC Connector (Sink Connector)
Language: Java - Size: 234 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0
zkan/introducing-kafka
Introducing Kafka
Language: Python - Size: 714 KB - Last synced at: about 1 month ago - Pushed at: 2 months ago - Stars: 0 - Forks: 17
kaiwaehner/ksql-udf-deep-learning-mqtt-iot
Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data
Language: Java - Size: 866 KB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 298 - Forks: 116
bakdata/streams-explorer
Explore Apache Kafka data pipelines in Kubernetes.
Language: Python - Size: 3.63 MB - Last synced at: 25 days ago - Pushed at: 2 months ago - Stars: 45 - Forks: 5
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: about 12 hours ago - Pushed at: over 3 years ago - Stars: 16 - Forks: 4
Mongey/terraform-provider-kafka-connect
Terraform provider for managing Apache Kafka Connect
Language: Go - Size: 5.45 MB - Last synced at: 4 days ago - Pushed at: about 1 month ago - Stars: 114 - Forks: 43
mikeroyal/Apache-Kafka-Guide
Apache Kafka Guide
Size: 203 KB - Last synced at: 12 days ago - Pushed at: over 3 years ago - Stars: 31 - Forks: 6
