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: about 6 hours ago - Pushed at: about 7 hours ago - Stars: 1,416 - Forks: 384

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: about 13 hours ago - Pushed at: about 14 hours ago - Stars: 8 - Forks: 16

confluentinc/kafka-connect-elasticsearch

Kafka Connect Elasticsearch connector

Language: Java - Size: 3.16 MB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 24 - Forks: 438

confluentinc/kafka-connect-hdfs

Kafka Connect HDFS connector

Language: Java - Size: 2.54 MB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 21 - Forks: 396

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.31 MB - Last synced at: 4 days ago - Pushed at: 8 days ago - Stars: 26 - Forks: 13

confluentinc/kafka-connect-jdbc

Kafka Connect connector for JDBC-compatible databases

Language: Java - Size: 15.3 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 23 - Forks: 975

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.3 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 5 - Forks: 0

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: 13 days ago - Pushed at: 13 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: 9 days ago - Pushed at: 15 days ago - Stars: 6 - Forks: 1

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: 17 days ago - Pushed at: 17 days ago - Stars: 4 - Forks: 0

microsoft/kafka-connect-cosmosdb

Kafka Connect connectors for Azure Cosmos DB

Language: Java - Size: 5.31 MB - Last synced at: 3 days ago - Pushed at: about 2 months ago - Stars: 54 - Forks: 54

sanjuthomas/kafka-connect-marklogic

Kafka Sink Connect MarkLogic

Language: Java - Size: 8.86 MB - Last synced at: 8 days ago - Pushed at: 10 months ago - Stars: 19 - Forks: 4

osodevops/CCAAK-Exam-Questions

Confluent Kafka questions to practice for CCAAK

Size: 32.2 KB - Last synced at: 8 days ago - Pushed at: about 2 months ago - Stars: 12 - Forks: 2

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: about 1 month ago - Pushed at: about 1 month ago - Stars: 325 - Forks: 69

Aiven-Open/opensearch-connector-for-apache-kafka

Aiven's OpenSearch® Connector for Apache Kafka®

Language: Java - Size: 936 KB - Last synced at: 17 days ago - Pushed at: about 2 months ago - Stars: 71 - Forks: 40

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: 12 days ago - Pushed at: 11 months ago - Stars: 54 - Forks: 14

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: 13 days ago - Pushed at: about 1 year ago - Stars: 171 - Forks: 85

Azure/kafka-sink-azure-kusto

Kafka sink for Kusto

Language: Java - Size: 2.48 MB - Last synced at: 14 days ago - Pushed at: about 1 month ago - Stars: 49 - Forks: 24

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: 5 days ago - Pushed at: 3 months ago - Stars: 7 - Forks: 11

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: 8 days ago - Pushed at: 10 months ago - Stars: 9 - Forks: 8

findinpath/kafka-connect-nested-set-jdbc-sink

JDBC Nested Set Sink Connector for Kafka Connect

Language: Java - Size: 1.39 MB - Last synced at: 20 days ago - Pushed at: about 2 years ago - Stars: 6 - Forks: 1

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 1 month ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

danielsobrado/CCDAK-Exam-Questions

Confluent Kafka questions to practice for CCDAK

Size: 335 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 90 - Forks: 32

devshawn/kafka-connect-healthcheck

🏥 A simple healthcheck wrapper to monitor Kafka Connect.

Language: Python - Size: 49.8 KB - Last synced at: 12 days ago - Pushed at: almost 4 years ago - Stars: 39 - Forks: 12

Mongey/kafka-connect-slack

Kafka Connect Sink for posting to Slack

Language: Kotlin - Size: 70.3 KB - Last synced at: 2 days ago - Pushed at: over 2 years ago - Stars: 9 - Forks: 7

ably/kafka-connect-ably

Kafka Connector for publishing data from Kafka to Ably

Language: Java - Size: 800 KB - Last synced at: 23 days ago - Pushed at: 9 months ago - Stars: 12 - Forks: 7

mmolimar/kafka-connect-fs

Kafka Connect FileSystem Connector

Language: Java - Size: 524 KB - Last synced at: 5 months ago - Pushed at: over 2 years ago - Stars: 110 - Forks: 77

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: 17 days ago - Pushed at: 6 months ago - Stars: 8 - Forks: 10

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

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: 12 days ago - Pushed at: over 3 years ago - Stars: 39 - Forks: 29

sanjuthomas/kafka-connect-arangodb

Kafka Sink Connect ArangoDB

Language: Java - Size: 83 KB - Last synced at: 8 days ago - Pushed at: 10 months ago - Stars: 10 - Forks: 2

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: 19 days ago - Pushed at: almost 3 years ago - Stars: 7 - Forks: 3

elgca/kafka-jslt-tansform

基于jstl的kafka connect的transform。使用jstl处理kafka json数据

Language: Java - Size: 19.5 KB - Last synced at: about 1 month ago - Pushed at: about 6 years ago - Stars: 1 - Forks: 0

renrenche/kafka-connectors

kafka connector 插件，支持输入 mysql binlog 和 json 格式写入ClickHouse。持续更新

Language: Java - Size: 51.8 KB - Last synced at: 4 months ago - Pushed at: over 4 years ago - Stars: 45 - Forks: 24

asaintsever/kafka-connect-http-sink

HTTP Sink connector for Kafka Connect

Language: Java - Size: 36.1 KB - Last synced at: 15 days ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 3

90poe/connectctl

A kafka connect util

Language: Go - Size: 30.5 MB - Last synced at: 16 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: 12 days ago - Pushed at: 10 months ago - Stars: 10 - Forks: 5

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

osodevops/.github

Size: 44.9 KB - Last synced at: 12 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

lepetitprinz/apache-kafka

Hands-on learning Apache Kafka

Language: Java - Size: 86.9 KB - Last synced at: 12 months ago - Pushed at: about 2 years 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

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

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: about 3 hours ago - Pushed at: about 1 year ago - Stars: 5 - 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

bereczdaniel/Streamline-Hackathon-2018

Application for the 2018 Streamline-Hackathon

Language: JavaScript - Size: 465 KB - Last synced at: about 1 year ago - Pushed at: almost 7 years ago - Stars: 0 - Forks: 0

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: 2 days ago - Pushed at: about 1 year ago - Stars: 1 - 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

yaravind/kafka-connect-jenkins

Kafka Connect Connector for Jenkins Open Source Continuous Integration Tool

Language: Java - Size: 192 KB - Last synced at: 5 months ago - Pushed at: over 2 years ago - Stars: 30 - Forks: 14

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

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

dhohirpradana/kafka-debezium

Kafka Debezium

Language: Python - Size: 45.6 MB - Last synced at: 12 months ago - Pushed at: about 2 years ago - Stars: 3 - 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

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: 4 months ago - Pushed at: 4 months ago - Stars: 28 - Forks: 16

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

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

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: 12 days ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0

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

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

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

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

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

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

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

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

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

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: over 1 year ago - Pushed at: about 8 years ago - Stars: 2 - Forks: 2

jaehyeon-kim/msk-connect-schema-registry

MSK Connect with External Schema Registry

Language: HCL - Size: 80.1 KB - Last synced at: 18 days ago - Pushed at: almost 2 years ago - Stars: 3 - Forks: 1

DarioBalinzo/kafka-connect-elasticsearch-source

Kafka Connect Elasticsearch Source

Language: Java - Size: 24.9 MB - Last synced at: over 1 year ago - Pushed at: almost 2 years ago - Stars: 55 - Forks: 36

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

nayekabhishek1/awesome-kafka

A curated list about Apache Kafka

Size: 24.4 KB - Last synced at: 6 days ago - Pushed at: over 2 years ago - Stars: 16 - Forks: 7

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

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: about 1 month ago - Pushed at: about 5 years ago - Stars: 29 - Forks: 13

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

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

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

iilunin/node-ws-kafka-connector

WebSocket to Kafka connector

Language: JavaScript - Size: 167 KB - Last synced at: about 2 years ago - Pushed at: over 7 years ago - Stars: 1 - Forks: 2

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: 12 days ago - Pushed at: about 4 years ago - Stars: 5 - Forks: 1

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 1 month 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

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

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

zigarn/kafka-connect-jmx

Kafka connect JMX Source Connector

Language: Java - Size: 16.6 KB - Last synced at: 12 days ago - Pushed at: almost 6 years ago - Stars: 7 - Forks: 6

natanhp/TCP-Client-Kafka-Connector

Kafka Connect connector for TCP Server

Language: Java - Size: 24.4 KB - Last synced at: 2 months ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0

code-star/kafka-connect-zeromq

Kafka connector for the ZeroMQ messaging library

Language: Scala - Size: 101 KB - Last synced at: about 1 month ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 0

startappdev/kafka-connect-mongodb

MongoDB sink connector for Kafka Connect

Language: Scala - Size: 11.9 MB - Last synced at: 12 months ago - Pushed at: almost 7 years ago - Stars: 14 - Forks: 9

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: about 3 years ago - Stars: 1 - Forks: 0

it21208/Data_Engineer_Code_Challenge

𝐔𝐬𝐞𝐫𝐬 𝐨𝐟 𝐜𝐞𝐭𝐚𝐢𝐧 𝐨𝐫𝐠𝐚𝐧𝐢𝐬𝐚𝐭𝐢𝐨𝐧 𝐟𝐫𝐨𝐧𝐭-𝐟𝐚𝐜𝐢𝐧𝐠 𝐬𝐢𝐭𝐞 𝐬𝐞𝐞 𝐭𝐡𝐞 𝐜𝐥𝐚𝐬𝐬𝐢𝐟𝐢𝐞𝐝𝐬 𝐭𝐡𝐚𝐭 𝐚𝐫𝐞 𝐞𝐧𝐭𝐞𝐫𝐞𝐝 𝐢𝐧 𝐭𝐡𝐞 𝐬𝐲𝐬𝐭𝐞𝐦𝐬 𝐛𝐲 𝐭𝐡𝐞𝐢𝐫 𝐜𝐮𝐬𝐭𝐨𝐦𝐞𝐫𝐬. 𝐖𝐡𝐞𝐧 𝐚 𝐜𝐮𝐬𝐭𝐨𝐦𝐞𝐫 𝐜𝐫𝐞𝐚𝐭𝐞𝐬 𝐚 𝐜𝐥𝐚𝐬𝐬𝐢𝐟𝐢𝐞𝐝, 𝐭𝐡𝐞 𝐬𝐲𝐬𝐭𝐞𝐦𝐬 𝐞𝐦𝐢𝐭 𝐚 𝐫𝐞𝐜𝐨𝐫𝐝 𝐨𝐟 𝐢𝐭 𝐚𝐧𝐝 𝐩𝐮𝐛𝐥𝐢𝐬𝐡 𝐢𝐭 𝐭𝐨 𝐚 𝐊𝐚𝐟𝐤𝐚 𝐭𝐨𝐩𝐢𝐜. 𝟏. 𝐂𝐫𝐞𝐚𝐭𝐞 𝐚𝐧 𝐚𝐩𝐩𝐥𝐢𝐜𝐚𝐭𝐢𝐨𝐧 𝐭𝐡𝐚𝐭 𝐜𝐨𝐧𝐬𝐮𝐦𝐞𝐬 𝐭𝐡𝐞𝐬𝐞 𝐫𝐞𝐜𝐨𝐫𝐝𝐬. 𝟐. 𝐑𝐞𝐜𝐨𝐫𝐝 𝐭𝐡𝐞𝐦 𝐢𝐧 𝐚 𝐌𝐲𝐒𝐐𝐋 𝐝𝐚𝐭𝐚𝐛𝐚𝐬𝐞. 𝟑. 𝐖𝐫𝐢𝐭𝐞 𝐚 𝐒𝐐𝐋 𝐬𝐜𝐫𝐢𝐩𝐭 𝐭𝐨 𝐚𝐧𝐚𝐥𝐲𝐬𝐞 𝐭𝐡𝐢𝐬 𝐢𝐧𝐟𝐨𝐫𝐦𝐚𝐭𝐢𝐨𝐧.

Language: Python - Size: 113 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 0

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

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: almost 2 years ago - Pushed at: over 4 years ago - Stars: 4 - 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

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: almost 4 years ago - Stars: 0 - 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: 17 days ago - Pushed at: 9 months ago - Stars: 1 - Forks: 1

sanjuthomas/kafka-connect-socket

Kafka Source Socket Connector

Language: Java - Size: 26.4 KB - Last synced at: 8 days ago - Pushed at: about 4 years ago - Stars: 0 - 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

ancur4u/kafka

Kafka PoC with Mule 4.2.2-HF2

Size: 2.93 KB - Last synced at: 14 days ago - Pushed at: almost 5 years ago - Stars: 0 - Forks: 1

latetrains/php-kafka-client

A PHP Client to communicate with Kafka

Language: PHP - Size: 3.91 KB - Last synced at: about 1 month ago - Pushed at: almost 5 years ago - Stars: 0 - Forks: 0

neeraj97/kafka-connect-github-source Fork of simplesteph/kafka-connect-github-source

Get a stream of issues and pull requests for your chosen GitHub repositories into Apache Kafka

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

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

BekyP/kafka-meetup-demo

sample of demo application used in second kafka meetup in bratislava

Language: Java - Size: 5.81 MB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0