Most popular kafka repositories and open source projects

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

saga-pattern-demo hifly81 Java

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

39 17 39

nginx-json-log fooinha C

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

38 19 38

sequelize-kafka-connect nodefluent JavaScript

:gem: nodejs kafka connect connector for MySQL, Postgres, SQLite and MSSQL

38 10 38

pcap-processor slgobinath Python

Read and process pcap files using this nifty tool

38 19 38

kafka-connect-examples tmcgrath Shell

Kafka Connect Examples

38 16 38

kafka2websocket Effyis HTML

Read Kafka topics with WebSockets

38 18 38

flask_kafka NimzyMaina Python

Flask Kafka consumer full implementation example. Ideal for a microservices architecture.

38 7 38

kafka-python-camera-stream akmamun Python

Distributed Streaming with Apache Kafka and Python OpenCV

38 19 38

conduktor-platform conduktor Shell

Streamline Apache Kafka with Conduktor Platform. 🚀

38 8 38

simple-push-center canyuegongzi TypeScript

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

38 15 38

storm-traffic wang1365 Java

使用Storm实时处理交通大数据（数据源：kafka，集群管理：zookeeper）

37 30 37

egg-kafka-node JohnApache JavaScript

kafka plugin for egg.js

37 5 37

kafkaer navdeepsekhon Java

Template based Kafka topic/cluster/ACL management

37 4 37

sample-message-driven-microservices piomin Java

sample spring cloud application that integrates with rabbitmq through spring cloud stream framework as shows how to setup message-driven microservices...

37 37 37

building-apache-kafka-connectors riferrei

This repository contains a sample project that can be used to start off your own source connector for Kafka Connect.

37 29 37

bigdata-book yuan-more

上百本大数据电子书，附带下载链接，包括计算机基础，Java，hadoop，spark，flink，kafka，hbase，hive，数仓等

37 10 37

Data-pipeline-project hiejulia Jupyter Notebook

Data pipeline project

37 23 37

xxhadoop junneyang Java

Data Analysis Using Hadoop/Spark/Storm/ElasticSearch/MachineLearning etc. This is My Daily Notes/Code/Demo. Don't fork, Just star !

36 16 36

BigDataTools winstonelei Java

tools for bigData

36 24 36

spark-utils LinMingQiang Scala

:boom: :alien: :hotsprings::rocket:Encapsulated spark 与其他组件的结合api，方便使用，例如 es，hbase，kudu，kafka，mq等

36 13 36

conduktor-gateway conduktor Java

Conduktor Gateway is a tool to intercept and then filter and transform requests and responses between clients and Apache Kafka

36 6 36

springboot-kafka-avro gAmUssA Java

A simple Spring Boot app that talks to Kafka using Avro and Schema Registry

36 37 36

kafka-notes anhthii

Comprehensible material for those who want to learn about Apache Kafka architecture.

36 18 36

dockerfiles jorgeacf Shell

Multi docker container images for main Big Data Tools. (Hadoop, Spark, Kafka, HBase, Cassandra, Zookeeper, Zeppelin, Drill, Flink, Hive, Hue, Mesos, ....

36 12 36

kafka-health-check deviceinsight Java

Health Check for Apache Kafka

36 16 36

joyce sourcesense Java

Joyce is a highly scalable event-driven Cloud Native Data Hub.

36 0 36

ContractTestingBoilerplate SrinivasanTarget Java

Contract Testing Boilerplate for the microservices developed using Spring Boot and Kafka in a maven multi-module project.

36 26 36

AsyncApi neuroglia-io C#

A .NET SDK for the Async API specification

36 3 36

kafka-connect-cosmosdb microsoft Java

Kafka Connect connectors for Azure Cosmos DB

36 50 36

hbase-packet-inspector kakao Clojure

Analyzes network traffic of HBase RegionServers

35 5 35

kafka-logback domclick Java

35 11 35

Petabridge.Tracing.Zipkin petabridge C#

Professionally supported Zipkin + OpenTracing driver in C#

35 4 35

Spring-Boot-2 celalaygar Java

Spring boot 2 türkçe örnekler

35 16 35

kafka-streams-running-topN lucasjellema JavaScript

Running Top N aggregation using Apache Kafka Streams

35 18 35

JAlgoArena jalgoarena Java

JAlgoArena programming contest platform

35 30 35

spring-rdbms-cdc-kafka-elasticsearch joumenharzli Java

Denormalize and Index MySQL database with ElasticSearch and Kafka

35 18 35

push ctodb Java

基于springboot & netty & kafka 实现的消息推送服务

35 22 35

pykafarr ikucan C++

A high-performance Python Kafka client. Efficiently from Kafka to Pandas and back.

35 6 35

awesome-netty NorthWard Java

netty到底能干什么? 这个项目告诉你, netty什么都能干

35 16 35

Kafka-quickstart MetaArivu Java

Kafka Examples focusing on Producer, Consumer, KStreams, KTable, Global KTable using Spring, Kafka Cluster Setup & Monitoring. Implementing Event So...

35 16 35

distributed-payment marselester Go

Demo execution of a payment transaction without an atomic commit across 3 partitions.

35 3 35

singlestore-logistics-sim singlestore-labs Go

Scalable package delivery logistics simulator built using SingleStore and Vectorized Redpanda

35 10 35

hercules vostok Java

Vostok Hercules is an open-source distributed system based on Apache Kafka and used for reliable delivery of telemetry data from microservices to stor...

35 9 35