Topic

kafka

Repositories (1207)

kafka-end-2-end-encryption
kafka-end-2-end-encryption salyh Java

De-/Serialization wrapper for Kafka to accomplish end to end encryption

34
distmq
distmq wenweihu86 Java

Distributed Message Queue based on Raft

34
kafka-with-microservices
kafka-with-microservices hakdogan Java

This repository is a tutorial for JUG Istanbul's Apache Kafka meetup that showing how Apache Kafka can be used in inter-microservices communication

34
go-graphql-subscription-example
go-graphql-subscription-example ccamel Go

☝️ go-graphql subscription over Kafka/Redis/NSQ example

34
netcore-microservices
netcore-microservices patrikduch C#

Advanced NET Microservice Architecture with Azure Kubernetes Services integration.

34
AnotherKafkaMonitor-AKM-
AnotherKafkaMonitor-AKM- triffic-tang Java

Another app which used to monitor the progress of Kafka Producer and Consumer

33
zipkin-storage-kafka
zipkin-storage-kafka openzipkin-contrib Java

Kafka-based storage for Zipkin.

33
kafka-configurator
kafka-configurator sky-uk Scala

Kafka Topic Configurator

33
spark-kafka-docker-demo
spark-kafka-docker-demo antlypls Scala

A sample project shows how to run Spark Streaming app with Kafka in Docker

33
kzmonitor
kzmonitor tqlihuiqi Python

kafka zookeeper monitor

33
sample-axon-kafka
sample-axon-kafka saikatkar Java

Sample CQRS and event sourced application developed on top of axon framework.(Kafka is used for distributing the events)

33
pusher
pusher topfreegames Go

A fast massive push platform for APNs and FCM

33
etl-engine
etl-engine hw2499 Go

etl engine 轻量级 跨平台 流批一体ETL引擎 数据抽取-转换-装载 ETL engine lightweight cross platform batch flow integration ETL engine data extraction t...

33
redpanda-examples
redpanda-examples redpanda-data Go

A collection of examples to demonstrate how to interact with Redpanda from various clients and languages.

33
kafka-connect-healthcheck
kafka-connect-healthcheck devshawn Python

🏥 A simple healthcheck wrapper to monitor Kafka Connect.

33
spark-sql-kafka-offset-committer
spark-sql-kafka-offset-committer HeartSaVioR Scala

Kafka offset committer for structured streaming query

33
typescript-event-sourcing-sample-app
typescript-event-sourcing-sample-app yerinadler TypeScript

Typescript API that implements CQRS & Event Sourcing

33
docker-repo
docker-repo JasonkayZK Shell

A repository stores some dockerfiles or docker-compose files for quickly starting service or service cluster.

33
kafka-swoole
kafka-swoole whiteCcinn PHP

☝️Implement all kafka protocols, providing 'HighLevel' and 'LowLevel' client apis respectively, and utilize swoole to realize collaboration and flexib...

32
kafka-compose
kafka-compose ksindi Python

:musical_score: Docker compose files for various kafka stacks

32
kafka-connectors-tests
kafka-connectors-tests lensesio Dockerfile

Test suite for Kafka Connect connectors based on Landoop's Coyote and docker.

32
kafka-rest-ui
kafka-rest-ui nodefluent JavaScript

Kafka REST UI 🍄

32
kafka-connect-dynamodb
kafka-connect-dynamodb shikhar Java

Kafka Connector for DynamoDB [unmaintained]

32
Real-time-log-analysis-system
Real-time-log-analysis-system 29DCH Java

:penguin:基于spark streaming+flume+kafka+hbase的实时日志处理分析系统(分为控制台版本和基于springboot、Echarts等的Web UI可视化版本)

32
springboot-kafka
springboot-kafka hcxin Java

springboot集成kafka

32
docker-kafka-kraft
docker-kafka-kraft moeenz Shell

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

32
o2k
o2k woqutech C++

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

32
zeek-kafka
zeek-kafka SeisoLLC Shell

A Zeek log writer plugin that publishes to Kafka.

32
kafka-message-scheduler
kafka-message-scheduler sky-uk Scala

Scheduler for low-frequency and long-term scheduling of delayed messages to Kafka topics.

32
np-flink
np-flink liuhouer Java

flink详细学习实践

32
df_data_service
df_data_service datafibers-community Java

DataFibers Data Service

31
asynckafka
asynckafka jmf-mordis Python

Fast kafka client for asyncio

31
sample-spring-cloud-stream-kafka
sample-spring-cloud-stream-kafka piomin Java

Demo illustrating the usage of Spring Cloud Stream in order to integrate with Kafka Streams

31
kafka-workers
kafka-workers RTBHOUSE Java

Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.

31
RecommendSystem
RecommendSystem Yifan122 Scala

电影推荐系统

31
amazon-msk-java-app-cdk
amazon-msk-java-app-cdk aws-samples Java

This project provides and example of end to end data processing application created using the combination of Amazon Managed Streaming for Apache Kafka...

31
connect-utils
connect-utils jcustenborder Java

Utility project for working with Kafka Connect.

31
kafka-connect-client
kafka-connect-client SourceLabOrg Java

A kafka-connect REST api client for java

31
mqtt-to-kafka-bridge
mqtt-to-kafka-bridge nodefluent JavaScript

Move your messages from MQTT to Apache Kafka in real-time :rocket:

31
kafka-example
kafka-example layonez Java

Example project for Spring Boot + Apache Kafka + Docker-compose solution

31
devbox
devbox joubertredrat Makefile

Run dev environments easily and fastly using docker

31
scylla-cdc-source-connector
scylla-cdc-source-connector scylladb Java

A Kafka source connector capturing Scylla CDC changes

31
govern-eventbus
govern-eventbus Ahoo-Wang Java

Govern Service RPC & Event-Driven Architecture Framework || Govern EventBus is no longer maintained, please use Wow instead.

31
magics
magics thpham Nix

My NixOps / NixOs experiments ( #k8s , #elk, #kafka / #zk clusters and #RaspberryPi3)

30
qwery
qwery ldaniels528 Scala

A SQL-like language for performing ETL transformations.

30
kafkacli
kafkacli fhussonnois Go

CLI and Go Clients to manage Kafka components (Kafka Connect & SchemaRegistry)

30
gosquito
gosquito livelace Go

gosquito ("go" + "mosquito") is a pluggable tool for data gathering, data processing and data transmitting to various destinations.

30
notifications
notifications technextacg CSS

Push Notification and Real Time Notification application on Angular 5, NodeJS, Apache Kafka, MongoDB with Spring Boot App

30
saga-pattern-example
saga-pattern-example victoramsantos Python

A Saga Pattern implementation with Kafka, MongoDb and Python.

30
franz
franz scrogson Rust

A Kafka client library for Erlang/Elixir based on librdkafka implemented as a safe Rust NIF.

30