De-/Serialization wrapper for Kafka to accomplish end to end encryption
Distributed Message Queue based on Raft
This repository is a tutorial for JUG Istanbul's Apache Kafka meetup that showing how Apache Kafka can be used in inter-microservices communication
☝️ go-graphql subscription over Kafka/Redis/NSQ example
Advanced NET Microservice Architecture with Azure Kubernetes Services integration.
Another app which used to monitor the progress of Kafka Producer and Consumer
Kafka-based storage for Zipkin.
Kafka Topic Configurator
A sample project shows how to run Spark Streaming app with Kafka in Docker
kafka zookeeper monitor
Sample CQRS and event sourced application developed on top of axon framework.(Kafka is used for distributing the events)
A fast massive push platform for APNs and FCM
etl engine 轻量级 跨平台 流批一体ETL引擎 数据抽取-转换-装载 ETL engine lightweight cross platform batch flow integration ETL engine data extraction t...
A collection of examples to demonstrate how to interact with Redpanda from various clients and languages.
🏥 A simple healthcheck wrapper to monitor Kafka Connect.
Kafka offset committer for structured streaming query
Typescript API that implements CQRS & Event Sourcing
A repository stores some dockerfiles or docker-compose files for quickly starting service or service cluster.
☝️Implement all kafka protocols, providing 'HighLevel' and 'LowLevel' client apis respectively, and utilize swoole to realize collaboration and flexib...
:musical_score: Docker compose files for various kafka stacks
Test suite for Kafka Connect connectors based on Landoop's Coyote and docker.
Kafka REST UI 🍄
Kafka Connector for DynamoDB [unmaintained]
:penguin:基于spark streaming+flume+kafka+hbase的实时日志处理分析系统(分为控制台版本和基于springboot、Echarts等的Web UI可视化版本)
springboot集成kafka
Apache Kafka Docker image using Kafka Raft metadata mode (KRaft). https://hub.docker.com/r/moeenz/docker-kafka-kraft
oracle to kafka cdc tools, Synchronize Oracle online redo log to kafka or other big data platforms in realtime
A Zeek log writer plugin that publishes to Kafka.
Scheduler for low-frequency and long-term scheduling of delayed messages to Kafka topics.
flink详细学习实践
DataFibers Data Service
Fast kafka client for asyncio
Demo illustrating the usage of Spring Cloud Stream in order to integrate with Kafka Streams
Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.
电影推荐系统
This project provides and example of end to end data processing application created using the combination of Amazon Managed Streaming for Apache Kafka...
Utility project for working with Kafka Connect.
A kafka-connect REST api client for java
Move your messages from MQTT to Apache Kafka in real-time :rocket:
Example project for Spring Boot + Apache Kafka + Docker-compose solution
Run dev environments easily and fastly using docker
A Kafka source connector capturing Scylla CDC changes
Govern Service RPC & Event-Driven Architecture Framework || Govern EventBus is no longer maintained, please use Wow instead.
My NixOps / NixOs experiments ( #k8s , #elk, #kafka / #zk clusters and #RaspberryPi3)
A SQL-like language for performing ETL transformations.
CLI and Go Clients to manage Kafka components (Kafka Connect & SchemaRegistry)
gosquito ("go" + "mosquito") is a pluggable tool for data gathering, data processing and data transmitting to various destinations.
Push Notification and Real Time Notification application on Angular 5, NodeJS, Apache Kafka, MongoDB with Spring Boot App
A Saga Pattern implementation with Kafka, MongoDb and Python.
A Kafka client library for Erlang/Elixir based on librdkafka implemented as a safe Rust NIF.