Most popular kafka repositories and open source projects

rdkafka php-enqueue PHP

[READ-ONLY] The Kafka Enqueue transport.

43 32 43

kafka-connect-redis jaredpetersen Java

📕 Kafka Connect source and sink connector for Redis

43 11 43

watermill-kafka ThreeDotsLabs Go

Kafka Pub/Sub for the Watermill project.

43 20 43

kafka-example that-coder JavaScript

Example Node.js kafka setup

42 27 42

kafka_cluster_example ErikJiang Go

:beetle: kafka cluster example

42 9 42

noah blak3mill3r Clojure

Kafka Streams in Clojure

42 3 42

microservices-observability xmlking Kotlin

🎉 Microservices Observability - Log Aggregation, Distributed Tracking, Metrics

42 17 42

hotdog reiseburo Rust

Hotdog is a syslog-to-Kafka forwarder which aims to get log entries into Apache Kafka as quickly as possible.

42 7 42

prometheus-labs jazzwang Shell

Example Docker Cluster for "Full Stack Monitoring and Notification with Prometheus and Grafana"

42 8 42

EngineeringTeam YBIGTA

와이빅타 엔지니어링팀의 자료를 정리해두는 곳입니다.

42 10 42

django-kafka-demo koslib Python

Django app demoing a middleware that logs all requests to a Kafka broker. Repository receives only security updates.

42 22 42

pulse silverswords Go

☁EventBus on Portable Pub/Sub Components☄

42 3 42

aws-cdk-managed-elkk aws-samples Python

Managed ELKK stack implemented with the AWS CDK

42 19 42

tamer laserdisc-io Scala

Standalone alternatives to Kafka Connect Connectors

42 14 42

schema-registry-transfer-smt OneCricketeer Java

Kafka Connect Transform to copy Avro schemas between Schema Registries

42 21 42

twitter-network-analysis memgraph JavaScript

Analyzing a network of tweets and retweets using graph algorithms

42 10 42

makinage maki-nage Python

Stream Processing Made Easy

42 1 42

kafkaproxy dajudge Java

kafkaproxy is a reverse proxy for the wire protocol of Apache Kafka.

42 7 42

storm-dynamic-spout salesforce Java

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

41 13 41

replicator mysql-time-machine Java

MySQL Replicator. Replicates MySQL tables to Kafka and HBase, keeping the data changes history in HBase.

41 23 41

etl-light yamrcraft Scala

A light Kafka to HDFS/S3 ETL library based on Apache Spark

41 21 41

MicroServicePractice zn-cn Go

微服务实践的demo

41 8 41

Joker tomasfabian C#

Reactive data changes from SQL server to .NET clients. SqlTableDependency extensions, Joker.OData, Joker.Redis, Joker.MVVM and ksqlDB LINQ provider

41 13 41

personal_book_library_web_project batux Java

Personal Book Library Web Project

41 13 41

cl-rdkafka SahilKang Common Lisp

Common Lisp library for Kafka

41 6 41

go-kafka-connect-couchbase Trendyol Go

The Go implementation of the Kafka Connect Couchbase.

41 6 41

metamorphosis leroy-merlin-br PHP

Easy and flexible Kafka Library for Laravel and PHP 7

41 8 41

hyperdrive AbsaOSS Scala

Extensible streaming ingestion pipeline on top of Apache Spark

41 13 41

asyncapi-validator WaleedAshraf JavaScript

Message validator for Kafka/RabbitMQ/Anything through AsyncAPI schema

41 9 41

lectures Romanow Java

Лекции по курсу Распределенные Системы Обработки Информации кафедры ИУ7 МГТУ им. Н.Э.Баумана

41 12 41

bigdata-doc aikuyun Shell

大数据学习笔记，学习路线，技术案例整理。

41 19 41

data-mesh-demo confluentinc Java

A Data Mesh prototype built on Confluent Cloud

41 33 41

springboot-kafka-course RameshMF Java

Source code of Spring boot + Apache Kafka Udemy Course

41 81 41

BigData mincloud1501 Java

빅데이터 pipeline 구성 요소 기술들에 관한 coding 실습 및 연구

41 11 41

prometheus-kafka-consumer-group-exporter kawamuray Go

Prometheus exporter for Kafka consumer group information obtained through `kafka-consumer-groups.sh`.

40 38 40

proximo uw-labs Go

Interoperable GRPC based publish/subscribe

40 16 40

real-time-stream-processing-engine NashTech-Labs Scala

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

40 21 40

practice kanwangzjm Java

40 18 40

skafka evolution-gaming Scala

Scala wrapper for kafka consumer and producer

40 13 40

spring-kafka-event-sourcing-sampler mguenther Java

Showcases how to build a small Event-sourced application using Spring Boot, Spring Kafka, Apache Avro and Apache Kafka

40 32 40

BookRecommenderSystem Wanfengyueluo

基于大数据的图书推荐系统

40 4 40

SZ-Metro kailanyue Java

深圳地铁大数据客流分析系统

40 11 40

Docker-Build-Script liaozihong Shell

使用Docker与Docker-compose快速搭建的一些中间件和软件环境，包括Redis哨兵、RocketMq、RabbitMq、Kafka、Mysql主从等等

40 20 40

kafkaml-anomaly-detection rodrigo-arenas Python

Project for real-time anomaly detection using Kafka and python

40 14 40

lightning zhaojun2066 Lua

服务收集app web h5 埋点信息，openresty 接受，推送到kafka

39 14 39

paraflow dbiir Java

A real-time analytical system for ID-associated data

39 30 39

Kafka TrackingSoft Perl

Perl implementation of Kafka API (official CPAN module)

39 26 39

BigDataRiver radek1st Jupyter Notebook

Simple demo implementation of Lambda and Kappa architectures using Python, Docker, Kafka, Spark and Cassandra

39 18 39

JNotes husying

Java 工程师必备的技术知识点，全力打造Java 程序员的技能体系知识库；主要体现在 Java 基础、算法、网络、后端框架、数据库、操作系统等方面知识整理。对于Java...

39 11 39

mirrormaker_topic_rename opencore Java

A message handler implementation for MirrorMaker to change the target topic name during mirroring.

39 28 39

kafka

Repositories (1207)