Topic: "kafka-connector"
akka/alpakka-kafka
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Language: Scala - Size: 4.48 MB - Last synced at: 13 days ago - Pushed at: 20 days ago - Stars: 1,416 - Forks: 384
erdemcer/kafka-connect-oracle
Kafka Source Connector For Oracle
Language: Java - Size: 3.34 MB - Last synced at: over 1 year ago - Pushed at: over 4 years ago - Stars: 346 - Forks: 168
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: 9 days ago - Pushed at: 10 days ago - Stars: 327 - Forks: 69
kaiwaehner/kafka-connect-iot-mqtt-connector-example
Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data
Language: Shell - Size: 500 KB - Last synced at: 6 months ago - Pushed at: about 5 years ago - Stars: 206 - Forks: 88
chaokunyang/jkes
A search framework and multi-tenant search platform based on java, kafka, kafka connect, elasticsearch
Language: Java - Size: 1.62 MB - Last synced at: about 1 month ago - Pushed at: about 1 year ago - Stars: 171 - Forks: 85
mmolimar/kafka-connect-fs
Kafka Connect FileSystem Connector
Language: Java - Size: 524 KB - Last synced at: 1 day ago - Pushed at: over 2 years ago - Stars: 111 - Forks: 77
danielsobrado/CCDAK-Exam-Questions
Confluent Kafka questions to practice for CCDAK
Size: 335 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 90 - Forks: 32
Aiven-Open/opensearch-connector-for-apache-kafka
Aiven's OpenSearch® Connector for Apache Kafka®
Language: Java - Size: 936 KB - Last synced at: about 1 month ago - Pushed at: 2 months ago - Stars: 71 - Forks: 40
DarioBalinzo/kafka-connect-elasticsearch-source
Kafka Connect Elasticsearch Source
Language: Java - Size: 24.9 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 55 - Forks: 36
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: about 1 month ago - Pushed at: 11 months ago - Stars: 54 - Forks: 14
microsoft/kafka-connect-cosmosdb
Kafka Connect connectors for Azure Cosmos DB
Language: Java - Size: 5.31 MB - Last synced at: 5 days ago - Pushed at: 3 months ago - Stars: 53 - Forks: 54
thestyleofme/flink-explore
基于canal/kafka conenct的mysql/oracle数据实时同步、flink rest api、flink sql以及udf
Language: Scala - Size: 7.24 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 50 - Forks: 18
Azure/kafka-sink-azure-kusto
Kafka sink for Kusto
Language: Java - Size: 2.48 MB - Last synced at: 3 days ago - Pushed at: 2 months ago - Stars: 49 - Forks: 24
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: 138 MB - Last synced at: 2 days ago - Pushed at: 10 days ago - Stars: 45 - Forks: 6
renrenche/kafka-connectors
kafka connector 插件，支持输入 mysql binlog 和 json 格式写入ClickHouse。持续更新
Language: Java - Size: 51.8 KB - Last synced at: 5 months ago - Pushed at: over 4 years ago - Stars: 45 - Forks: 24
canelmas/kafka-connect-field-and-time-partitioner
Kafka Connect Store Partitioner by custom fields and time
Language: Java - Size: 24.4 KB - Last synced at: about 1 month ago - Pushed at: over 3 years ago - Stars: 39 - Forks: 29
devshawn/kafka-connect-healthcheck
🏥 A simple healthcheck wrapper to monitor Kafka Connect.
Language: Python - Size: 49.8 KB - Last synced at: about 1 month ago - Pushed at: almost 4 years ago - Stars: 39 - Forks: 12
yaravind/kafka-connect-jenkins
Kafka Connect Connector for Jenkins Open Source Continuous Integration Tool
Language: Java - Size: 192 KB - Last synced at: 9 days ago - Pushed at: over 2 years ago - Stars: 30 - Forks: 14
alibaba-archive/kafka-connect-mongo 📦
Kafka mongo connector (deeply inspired by https://github.com/DataReply/kafka-connect-mongodb)
Language: Kotlin - Size: 486 KB - Last synced at: 6 days ago - Pushed at: over 5 years ago - Stars: 29 - Forks: 13
ipa-digitools/simple-kafka-mqtt-connector
This application receives messages from a mqtt broker and sends the messages to a kafka cluster. Topic mapping is configurable.
Language: Java - Size: 26 MB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 28 - Forks: 16
apache/pekko-connectors-kafka
Apache Pekko Kafka Connector - Pekko-Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.
Language: Scala - Size: 3.32 MB - Last synced at: 2 days ago - Pushed at: 16 days ago - Stars: 26 - Forks: 13
confluentinc/kafka-connect-elasticsearch
Kafka Connect Elasticsearch connector
Language: Java - Size: 3.23 MB - Last synced at: 1 day ago - Pushed at: 2 days ago - Stars: 24 - Forks: 438
confluentinc/kafka-connect-jdbc
Kafka Connect connector for JDBC-compatible databases
Language: Java - Size: 15.3 MB - Last synced at: 1 day ago - Pushed at: 6 days ago - Stars: 24 - Forks: 975
confluentinc/kafka-connect-hdfs
Kafka Connect HDFS connector
Language: Java - Size: 2.55 MB - Last synced at: 1 day ago - Pushed at: 2 days ago - Stars: 21 - Forks: 396
guilhermegarcia86/kafka-series
Language: Java - Size: 533 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 20 - Forks: 16
sanjuthomas/kafka-connect-marklogic
Kafka Sink Connect MarkLogic
Language: Java - Size: 8.86 MB - Last synced at: 2 days ago - Pushed at: 11 months ago - Stars: 19 - Forks: 4
nayekabhishek1/awesome-kafka
A curated list about Apache Kafka
Size: 24.4 KB - Last synced at: about 15 hours ago - Pushed at: almost 3 years ago - Stars: 17 - Forks: 7
dmathieu/kafka-connect-opensearch 📦
Kafka Connect plugin for sending events to OpenSearch
Language: Java - Size: 229 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 17 - Forks: 5
rueedlinger/kafka-connect-quickstart
Example project to play around with Apache Kafka Connect. There are examples to develop and deploy Kafka Connect plugins (connectors, transforms, etc.) from a Java Maven project.
Language: Java - Size: 91.8 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 16 - Forks: 13
startappdev/kafka-connect-mongodb
MongoDB sink connector for Kafka Connect
Language: Scala - Size: 11.9 MB - Last synced at: about 1 year ago - Pushed at: almost 7 years ago - Stars: 14 - Forks: 9
ably/kafka-connect-ably
Kafka Connector for publishing data from Kafka to Ably
Language: Java - Size: 800 KB - Last synced at: 12 days ago - Pushed at: 10 months ago - Stars: 13 - Forks: 7
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
90poe/connectctl
A kafka connect util
Language: Go - Size: 30.5 MB - Last synced at: 10 days ago - Pushed at: almost 3 years ago - Stars: 12 - Forks: 2
sanjuthomas/kafka-connect-orientdb
Kafka Sink Connect OrientDB https://www.confluent.io/hub/sanjuthomas/kafka-connect-orientdb
Language: Java - Size: 155 KB - Last synced at: 2 days ago - Pushed at: 11 months ago - Stars: 10 - Forks: 5
sanjuthomas/kafka-connect-arangodb
Kafka Sink Connect ArangoDB
Language: Java - Size: 83 KB - Last synced at: 2 days ago - Pushed at: 11 months ago - Stars: 10 - Forks: 2
exasol/kafka-connect-jdbc-exasol 📦
Exasol dialect for the Kafka Connect JDBC Connector
Language: Java - Size: 847 KB - Last synced at: about 1 year ago - Pushed at: almost 3 years ago - Stars: 10 - Forks: 7
sanjuthomas/kafka-connect-gcp-bigtable
Kafka Sink Connect to GCP Bigtable - https://www.confluent.io/hub/sanjuthomas/kafka-connect-gcp-bigtable
Language: Java - Size: 506 KB - Last synced at: 2 days ago - Pushed at: 11 months ago - Stars: 9 - Forks: 8
Mongey/kafka-connect-slack
Kafka Connect Sink for posting to Slack
Language: Kotlin - Size: 70.3 KB - Last synced at: 6 days ago - Pushed at: over 2 years ago - Stars: 9 - Forks: 7
huangyueranbbc/KafkaDemo
Kafka整理
Language: Java - Size: 97.7 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 9 - Forks: 8
marklogic/kafka-marklogic-connector
A Kafka connector for subscribing to topics and streaming messages into MarkLogic
Language: Java - Size: 33.3 MB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 8 - Forks: 16
datastax/pulsar-3rdparty-connector
This project provides simple templates and instructions to build Apache Pulsar connectors on base of the existing Apache Kafka connectors.
Language: Shell - Size: 845 KB - Last synced at: 13 days ago - Pushed at: 6 months ago - Stars: 8 - Forks: 10
LeonardoBonacci/kafka-connect-tile38-sink
Kafka Connect Sink Connector for Tile38 https://www.confluent.io/connector/ka…
Language: Java - Size: 272 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 8 - Forks: 3
canertosuner/postgresql-change-data-capture-using-debezium
PostgreSQL Change Data Capture (CDC) Using Debezium Connector
Size: 6.84 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 8 - Forks: 0
DataDog/datadog-kafka-connect-logs
A plugin for Kafka Connect to send Kafka records as logs to Datadog.
Language: Java - Size: 417 KB - Last synced at: 19 days ago - Pushed at: 3 months ago - Stars: 7 - Forks: 11
SINTEF-9012/kafka-prometheus-sink-connector
A hackable Kafka sink connector to "push" (expose HTTP endpoint) data into Prometheus
Language: Java - Size: 3.17 MB - Last synced at: 17 days ago - Pushed at: almost 3 years ago - Stars: 7 - Forks: 3
zigarn/kafka-connect-jmx
Kafka connect JMX Source Connector
Language: Java - Size: 16.6 KB - Last synced at: about 1 month ago - Pushed at: about 6 years ago - Stars: 7 - Forks: 6
scholzj/echo-sink
Kafka Connect plugin which logs messages into log
Language: Java - Size: 25.4 KB - Last synced at: 29 days ago - Pushed at: about 1 month ago - Stars: 6 - Forks: 1
sentoz/kafka-connect-restart
utils for check status connectors and restart if status failed
Language: Shell - Size: 74.2 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 6 - Forks: 3
findinpath/kafka-connect-nested-set-jdbc-sink
JDBC Nested Set Sink Connector for Kafka Connect
Language: Java - Size: 1.39 MB - Last synced at: about 1 month ago - Pushed at: about 2 years ago - Stars: 6 - Forks: 1
Lightstreamer/Lightstreamer-kafka-connector
Last-mile data streaming. Stream real-time Kafka data to mobile and web apps, anywhere. Scale Kafka to millions of clients.
Language: Java - Size: 58.5 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 5 - Forks: 0
kameshsampath/grpc-todo-app
A demo to show how to get started with building Data Streaming API using https://grpc.de) and https://redpanda.com, and how to add analytics using https://snowflake.com e.g. a https://streamlit.io dashboard.
Language: Go - Size: 119 KB - Last synced at: 20 days ago - Pushed at: about 1 year ago - Stars: 5 - Forks: 0
ifsantana/NetArchSample
Event Driven Sample Archtecture using DDD, CQRS, Hexagonal / Ports and Adapters Pattern http://wiki.c2.com/?PortsAndAdaptersArchitecture
Language: C# - Size: 162 KB - Last synced at: about 1 month ago - Pushed at: about 4 years ago - Stars: 5 - Forks: 1
BerkOzdilek/emq_kafka_bridge
Send client events to Kafka
Language: Erlang - Size: 51.8 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 5 - Forks: 2
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: 15 days ago - Pushed at: 15 days ago - Stars: 4 - Forks: 0
hpsony94/kafka-conn
Kafka-conn is a Kafka Connector provisioning as a code following Gitops concept by using Gitlab.
Language: Shell - Size: 5.86 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 4 - Forks: 0
BerkOzdilek/emq_kafka-bridge_docker
emqtt with redis auth plugin, kafka bridge
Language: Shell - Size: 73.2 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 4 - Forks: 0
arangodb/kafka-connect-arangodb
Kafka Connect ArangoDB Sink Connector
Language: Java - Size: 9.96 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 3 - Forks: 0
research-virtualfortknox/simple-kafka-msb-connector
This application writes MSB events into Kafka and publishes Kafka messages as MSB events to the Manufacturing Service Bus.
Language: Java - Size: 61.5 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 3 - Forks: 3
Andrea-Cavallo/apachecamel-debezium
An example project to showcase the capabilities of Apache Camel together with technologies like Kafka, Debezium, Artemis, and more.
Language: Java - Size: 147 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 3 - Forks: 0
jaehyeon-kim/msk-connect-schema-registry
MSK Connect with External Schema Registry
Language: HCL - Size: 80.1 KB - Last synced at: about 1 month ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 1
dhohirpradana/kafka-debezium
Kafka Debezium
Language: Python - Size: 45.6 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0
MichaelHussey/SolaceKafkaSourceConnector
Kafka Source Connector for Solace Messaging
Language: Java - Size: 362 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 3 - Forks: 0
sami12rom/kafka-connect-gitlab
Building Kafka Connectors for Gitlab with Kotlin
Language: Kotlin - Size: 74.2 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0
anvaari/connector-guardian Fork of sentoz/kafka-connect-restart
Guardian for your Kafka Connect connectors. It check status of connectors and tasks and restart if they are failed
Language: Python - Size: 88.9 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 1
humio/kafka-connect-hec-sink
Kafka Connect sink for Humio HEC
Language: Java - Size: 118 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 4
asaintsever/kafka-connect-http-sink
HTTP Sink connector for Kafka Connect
Language: Java - Size: 36.1 KB - Last synced at: about 1 month ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 3
code-star/kafka-connect-zeromq
Kafka connector for the ZeroMQ messaging library
Language: Scala - Size: 101 KB - Last synced at: 2 months ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 0
it21208/Data_Engineer_Code_Challenge
𝐔𝐬𝐞𝐫𝐬 𝐨𝐟 𝐜𝐞𝐭𝐚𝐢𝐧 𝐨𝐫𝐠𝐚𝐧𝐢𝐬𝐚𝐭𝐢𝐨𝐧 𝐟𝐫𝐨𝐧𝐭-𝐟𝐚𝐜𝐢𝐧𝐠 𝐬𝐢𝐭𝐞 𝐬𝐞𝐞 𝐭𝐡𝐞 𝐜𝐥𝐚𝐬𝐬𝐢𝐟𝐢𝐞𝐝𝐬 𝐭𝐡𝐚𝐭 𝐚𝐫𝐞 𝐞𝐧𝐭𝐞𝐫𝐞𝐝 𝐢𝐧 𝐭𝐡𝐞 𝐬𝐲𝐬𝐭𝐞𝐦𝐬 𝐛𝐲 𝐭𝐡𝐞𝐢𝐫 𝐜𝐮𝐬𝐭𝐨𝐦𝐞𝐫𝐬. 𝐖𝐡𝐞𝐧 𝐚 𝐜𝐮𝐬𝐭𝐨𝐦𝐞𝐫 𝐜𝐫𝐞𝐚𝐭𝐞𝐬 𝐚 𝐜𝐥𝐚𝐬𝐬𝐢𝐟𝐢𝐞𝐝, 𝐭𝐡𝐞 𝐬𝐲𝐬𝐭𝐞𝐦𝐬 𝐞𝐦𝐢𝐭 𝐚 𝐫𝐞𝐜𝐨𝐫𝐝 𝐨𝐟 𝐢𝐭 𝐚𝐧𝐝 𝐩𝐮𝐛𝐥𝐢𝐬𝐡 𝐢𝐭 𝐭𝐨 𝐚 𝐊𝐚𝐟𝐤𝐚 𝐭𝐨𝐩𝐢𝐜. 𝟏. 𝐂𝐫𝐞𝐚𝐭𝐞 𝐚𝐧 𝐚𝐩𝐩𝐥𝐢𝐜𝐚𝐭𝐢𝐨𝐧 𝐭𝐡𝐚𝐭 𝐜𝐨𝐧𝐬𝐮𝐦𝐞𝐬 𝐭𝐡𝐞𝐬𝐞 𝐫𝐞𝐜𝐨𝐫𝐝𝐬. 𝟐. 𝐑𝐞𝐜𝐨𝐫𝐝 𝐭𝐡𝐞𝐦 𝐢𝐧 𝐚 𝐌𝐲𝐒𝐐𝐋 𝐝𝐚𝐭𝐚𝐛𝐚𝐬𝐞. 𝟑. 𝐖𝐫𝐢𝐭𝐞 𝐚 𝐒𝐐𝐋 𝐬𝐜𝐫𝐢𝐩𝐭 𝐭𝐨 𝐚𝐧𝐚𝐥𝐲𝐬𝐞 𝐭𝐡𝐢𝐬 𝐢𝐧𝐟𝐨𝐫𝐦𝐚𝐭𝐢𝐨𝐧.
Language: Python - Size: 113 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 2 - Forks: 0
imanzano/GoldenGateConfluentKafkaConnector
This is a fork of Original Oracle Golden gate Kafka connector for Confluent (https://java.net/projects/oracledi/downloads/directory/GoldenGate/Oracle%20GoldenGate%20Adapter%20for%20Kafka%20Connect) but fixing the compilation for GG Big Data 12.3.0.1.0.012
Language: Java - Size: 323 KB - Last synced at: almost 2 years ago - Pushed at: about 8 years ago - Stars: 2 - Forks: 2
aranbarri/kafka-local-uploader
Monitors a local directory and sends newly added files to Kafka, encoded in Base64.
Language: Java - Size: 6.69 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 1 - Forks: 0
soumyadip007/Distributed-System-Message-Broking-Log-Monitoring-using-Websocket-Netflix-OSS-Kafka-and-Microservice
A message broker is an architectural pattern for message validation, transformation, and routing. It mediates communication among applications, minimizing the mutual awareness that applications should have of each other in order to be able to exchange messages, effectively implementing decoupling.
Language: Java - Size: 70.3 KB - Last synced at: about 1 month ago - Pushed at: 9 months ago - Stars: 1 - Forks: 1
BaseMax/KafkaDataProcessingGo
Welcome to the Kafka Data Processing with Go project! This project showcases how to use Apache Kafka in combination with the Go programming language to build a data processing application.
Language: Go - Size: 44.9 KB - Last synced at: 4 days ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0
vrup0408/SnowIoT
The goal is to read real-time car telematic data, flatten and aggregate it utilizing Snowflake's advanced capabilities such as Dynamic tables, Snowpipe streaming and so on, in order to generate useful insights that will allow us to understand driver behavior.
Language: Python - Size: 1.69 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0
mgarmes/kafka-mirror-connector
kafka-connect-mirror is a Kafka Connector for mirroring data between Kafka clusters.
Language: Java - Size: 60.5 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 2
cevoaustralia/data-lake-demo
Data lake demo using change data capture (CDC) on AWS
Language: PLpgSQL - Size: 215 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 3
IrlanFreitas/franz
Esse repositório é a coleção de conhecimentos relacionados ao Kafka e o Alura na sua formação sobre. Abordaremos essa plataforma de streaming distribuído, veremos sobre producers, processors, consumers, cluster, sobre replicação de dados e como lidar com os erros e muito mais.
Size: 2.93 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 1 - Forks: 0
stephan-mueller/kafka-mq-bridging-showcase 📦
The showcase demonstrates bridging messages from Apache Kafka to IBM MQ and vice versa
Language: Java - Size: 417 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 1 - Forks: 1
elgca/kafka-jslt-tansform
基于jstl的kafka connect的transform。使用jstl处理kafka json数据
Language: Java - Size: 19.5 KB - Last synced at: about 2 months ago - Pushed at: about 6 years ago - Stars: 1 - Forks: 0
oridonner/kafka-connect-twitter-pipeline
Different Twitter Kafka Connect configurations
Size: 12 MB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0
sakib142/asynchronous-interservice-communication
Solution for interservice communication between various microservices using kafka and kinesis
Language: Java - Size: 40 KB - Last synced at: about 2 years ago - Pushed at: almost 7 years ago - Stars: 1 - Forks: 0
giuliocalzolari/golang-kafka-kinesis-connector
Kafka to Kinesis Connector
Language: Go - Size: 17.6 KB - Last synced at: about 2 years ago - Pushed at: about 7 years ago - Stars: 1 - Forks: 0
iilunin/node-ws-kafka-connector
WebSocket to Kafka connector
Language: JavaScript - Size: 167 KB - Last synced at: about 2 years ago - Pushed at: almost 8 years ago - Stars: 1 - Forks: 2
laoshancun/luardkafka Fork of mistsv/luardkafka
luardkafka is lua client for Apache Kafka.
Language: Lua - Size: 7.81 KB - Last synced at: about 2 years ago - Pushed at: almost 8 years ago - Stars: 1 - Forks: 0
osodevops/.github
Size: 51.8 KB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 0 - Forks: 0
simplydemo/simplydemo-kafka-fullname-transform
This is a sample that implements a custom Transform module used in the Kafka connector.
Language: Java - Size: 11.7 KB - Last synced at: about 2 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0
HikariJadeEmpire/Kafka_SandBox_byDocker
Kafka sandbox by docker
Language: Jupyter Notebook - Size: 971 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0
Informatievlaanderen/kafka-topic-transfer
Transfer topic data from one topic to other.
Language: C# - Size: 3.14 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0
andremfaria/alarm-system-kafka
An alarm system that monitor hosts' CPU & memory indicators and send notifications according to user configurations
Language: Java - Size: 46.9 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
jessepinkman9900/postgres-cdc
Postgres change data capture using Debezium
Language: Dockerfile - Size: 20.5 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
Tzur1234/Optimizing-Public-Transportation
I built a real-time event pipeline using Apache Kafka and its ecosystem, simulating and displaying Chicago Transit Authority train line statuses using public data.
Language: Python - Size: 319 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
hung2xt/debezium-kafka-spark
Change Data Capture (CDC) refers to sourcing database change events from a source database. While there are commercial solutions available in the market, Debezium is available as an open-source option. In this blog post, I am going to show you how to install the Debezium MySQL Connector on Ubuntu machines using Google VM instances.
Language: Python - Size: 47.9 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0
lepetitprinz/apache-kafka
Hands-on learning Apache Kafka
Language: Java - Size: 86.9 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0
Noctsol/k8s-confluentcloud-kafka-connect
Contains example of using self-managed connectors on k8s to confluent cloud Kafka.
Size: 11.7 KB - Last synced at: over 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0
amit1563/thirdparty
This repo helps to create customize image and push it to private docker registry. These images will be used by deployments repo.
Language: Dockerfile - Size: 10.7 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
subpath/kafka-to-postgresql
Language: Python - Size: 5.86 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1
natanhp/TCP-Client-Kafka-Connector
Kafka Connect connector for TCP Server
Language: Java - Size: 24.4 KB - Last synced at: 3 months ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0
felipegutierrez/kafka-connector-github-source
This is a GitHub Kafka source connector. It consumes issues from a Github repo and published them on a Kafka topic.
Language: Java - Size: 69.3 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0
leochinaliu/flink-connector-kafka-extend
extend flink-connector-kafka
Language: Java - Size: 32.2 KB - Last synced at: over 1 year ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 1
sanjuthomas/kafka-connect-socket
Kafka Source Socket Connector
Language: Java - Size: 26.4 KB - Last synced at: 2 days ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0
ancur4u/kafka
Kafka PoC with Mule 4.2.2-HF2
Size: 2.93 KB - Last synced at: about 1 month ago - Pushed at: almost 5 years ago - Stars: 0 - Forks: 1
