Most popular kafka repositories and open source projects

simple-push-center canyuegongzi TypeScript

基于nest的推送系统（集成kafka消息， redis任务队列），可实现对邮箱手机号 websocket app客户端的消息推送

44 14 3

springboot-chowder 503612012 Java

springboot大杂烩

44 19 2

o2k woqutech C++

oracle to kafka cdc tools, Synchronize Oracle online redo log to kafka or other big data platforms in realtime

44 15 4

docker-kafka-kraft moeenz Shell

Apache Kafka Docker image using Kafka Raft metadata mode (KRaft). https://hub.docker.com/r/moeenz/docker-kafka-kraft

44 27 1

big-data-streets ymericson Scala

Big Data webapp using Chicago street congestion, crashes, red light violations, and speed camera violations

44 25 2

chat-server ramank775 JavaScript

A chat server based on the microservice architecture to ensure high availability, high throughput, horizontal scalability

44 15 44

bigdata-interview yuan-more

2021年超全超详细的最新大数据开发面试题，附答案解析，大数据面试题，看这一套就够了

44 15 44

streaming-sales-generator garystafford Python

Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python

44 21 1

spark_streaming_kafka_offset E-SoulDataGroup Scala

SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失

43 41 43

SpringBoot-Mall Philomon Java

SpringBoot商城系统Demo，主要功能：提供了商城系统的后端Api，不包含前端页面，体现了前后端解耦分离的思想。实现了商品，购物车，订单系统，单点登录系统等4个...

43 15 3

noah blak3mill3r Clojure

Kafka Streams in Clojure

43 3 8

microservices-observability xmlking Kotlin

🎉 Microservices Observability - Log Aggregation, Distributed Tracking, Metrics

43 15 5

Kafka TrackingSoft Perl

Perl implementation of Kafka API (official CPAN module)

43 28 10

mirrormaker_topic_rename opencore Java

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

43 28 43

kafka-connect-examples tmcgrath Shell

Kafka Connect Examples

43 19 43

Hyperionn oslabs-beta JavaScript

An open-source visualization tool for monitoring Kafka cluster metrics

43 2 43

twitter-network-analysis memgraph JavaScript

Analyzing a network of tweets and retweets using graph algorithms

43 9 2

aiven-examples aiven HCL

Aiven "getting started" code examples

43 24 43

ksqldb-go thmeitz Go

ksqldb-go client

43 10 43

pathway-examples pathway-labs

Code examples for the Pathway programming framework

43 6 43

airflow_kafka_cassandra_mongodb dogukannulu Python

Produce Kafka messages, consume them and upload into Cassandra, MongoDB.

43 25 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

prometheus-labs jazzwang Shell

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

42 8 2

remoting-kafka-plugin jenkinsci Java

Jenkins Remoting over Apache Kafka

42 14 10

EngineeringTeam YBIGTA

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

42 10 10

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 1

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 6

nginx-json-log fooinha C

Highly configurable JSON format logging per Location - nginx logging module - aka. kasha 🍲

42 18 6

makinage maki-nage Python

Stream Processing Made Easy

42 1 3

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

metamorphosis leroy-merlin-br PHP

Easy and flexible Kafka Library for Laravel and PHP 7

41 8 41

data-mesh-demo confluentinc Java

A Data Mesh prototype built on Confluent Cloud

41 33 41

lectures Romanow Java

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

41 12 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

BigDataRiver radek1st Jupyter Notebook

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

40 18 2

kafkaer navdeepsekhon Java

Kafka infra as code. Template based Kafka topic/cluster/ACL management

40 8 5

BigData mincloud1501 Java

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

40 12 5

saga-pattern-demo hifly81 Java

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

40 16 1

SZ-Metro kailanyue Java

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

40 11 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

Repositories (1422)