Most popular kafka repositories and open source projects

flow-exporter

Export network flows from Kafka to Prometheus

18   100   100  

avrora

A convenient Elixir library to work with Avro messages, schemas and Co...

35   100   100  

vscode-kafka

Apache Kafka® extension for Visual Studio Code

34   100   100  

kafka-junit

JUnit rule for spinning up a Kafka broker

44   99   99  

MysqlToAll

A Mysql data to file/elasticsearch/kafka/redis/redis-cluster/mongodb(...

17   99   99  

kafka-go-example

kafka-go-example 以及系列教程

25   99   99  

ksqlDB.RestApi.Client-DotNet

ksqlDb.RestApi.Client is a C# LINQ-enabled client API for issuing and...

25   98   98  

kafka-connect-protobuf-converter

Protobuf converter plugin for Kafka Connect

52   98   98  

terraform-provider-kafka-connect

Terraform provider for managing Apache Kafka Connect

37   98   98  

dotnet-avro

An Avro implementation for .NET

35   98   98  

spring-cloud-stream-kafka-elasticsearch

The goal of this project is to implement a "News" processing pipeline...

50   98   98  

stormkafkamon

Dumps state of Storm Kafka consumers

50   97   97  

streamx

kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)

54   97   97  

kafka4s

Functional programming with Kafka and Scala

18   97   97  

snowflake-kafka-connector

Snowflake Kafka Connector (Sink Connector)

77   97   97  

Go-CQRS-EventSourcing-Microservice

Go-CQRS-EventSourcing-Microservice

21   97   97  

kafkawize

Kafkawize : A Self service Apache Kafka Topic Management tool/portal....

11   94   94  

datagen

Generate authentic looking mock data based on a SQL, JSON or Avro sche...

8   93   93  

schema-registry-gitops

Manage Confluent Schema Registry subjects through Infrastructure as co...

16   92   92  

kaufmann_ex

Kafka backed service library.

7   92   92  

microservices-change-data-capture-with-debezium

Microservices data exchange with change data capture and outbox patte...

20   92   92  

khermes

A distributed fake data generator based in Akka.

32   91   91  

kafka-connect-web

Web tool for operating kafka connect https://hub.docker.com/r/official...

6   90   90  

Streamis

Streaming application development and management system, based on Link...

35   89   89  

debezium-incubator

Previously used repository for new Debezium modules and connectors in...

80   89   89  

kafka

Development repository for the kafka cookbook

109   89   89  

bigpipe

以Kafka为存储介质，提供异步Http RPC的中间件

25   89   89  

open-bank-mark

A bank simulation application using mainly Clojure, which can be used...

15   89   89  

camus

Mirror of Linkedin's Camus

63   88   88  

netscaler-observability-exporter

Exports logs and metrics from Citrix ADC to various observability tool...

14   88   88  

messenger-kafka

Simple Kafka transport for Symfony Messenger.

37   88   88  

kafka-connect-twitter

Kafka Connect Sink/Source for Twitter

44   87   87  

ksql-jdbc-driver

JDBC driver for Apache Kafka

19   87   87  

turnstyl

turnstyl is an open-source ETL data integrity monitoring node package...

14   87   87  

kafta

Kafta is a command line for managing Kafka clusters

5   87   87  

Ozon-Go-Course

🎓 Ozon Go Course

37   86   86  

data-processing-pipeline

Real-Time Data Processing Pipeline & Visualization with Docker, Spark,...

29   86   86  

spring-cloud-stream-demo

Simple Event Driven Microservices with Spring Cloud Stream

71   86   86  

dockerfiles

docker 快速搭建稳定安全的开发/生产环境

34   84   84  

BigDataParty

大数据组件 All-in-One 的 Dockerfile

29   84   84  

kafka-elk-docker-compose

Deploy ELK stack and kafka with docker-compose

75   84   84  

springboot-kafka-connect-debezium-ksqldb

Experiment with Kafka, Debezium, and ksqlDB. research-service: Perform...

48   84   84  

mydataharbor

:cn: MyDataHarbor是一个致力于解决任意数据源到任意数据源的分布式、高扩...

14   84   84  

bigdata-hub

数据建设与大数据技术知识体系，包含hadoop、hive、spark、flink主流框架和...

30   84   84  

xk6-kafka

k6 extension to load test Apache Kafka with support for various serial...

45   83   83  

community

仿照牛客网实现的讨论区。

27   83   83  

go-consumergroup

golang kafka consumer group

15   83   83  

euphoria

Euphoria is an open source Java API for creating unified big-data proc...

11   83   83  

gmqtt

Golang MQTT Broker.

12   83   83  

kafka-nodejs-example

Showcases using Kafka with a producer (writes messages to PostgreSQL)...

42   83   83