kafka

Using KarateDSL to test Kafka applications

Strimzi canary

Go event sourcing with Kafka, example project

Kafka mongo connector (deeply inspired by https://github.com/DataReply/kafka-connect-mongodb)

✨ A message queue client framework (Kafka & ActiveMQ & RocketMQ)

💡 Modern Fullstack Application for Sharing Fastlane Ideas

基于Akka实现的数据实时流式同步的应用,支持高可用

yet another databus that transfer/transform pipeline data between plugins

Kafka on Kubernetes with Strimzi

CQRS implementation using Debezium + Spring Cloud Stream + Kafka Connect + Kafka + Druid

Fully Managed Apache Kafka Cluster with Ansible & Terraform.

End-to-end Snowplow Analytics Pipeline for real time events

Kafka Connect Store Partitioner by custom fields and time

🌀 Ultimate Docker Compose to rule them all.

A Kafka Cookbook for Chef

An opinionated Kafka producer/consumer built on top of confluent-kafka-python/librdkafka

Demo code from my talk @ Codemotion Milan 2018 - "Building event sourced systems with Kafka Streams"

Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)

Pan is a high performance mq proxy,support kafka,rabbit-mq,rocketmq,nsq and other mq

A DNS server written in Go with an event stream architecture, updated via kafka

Stream your process history to Kafka

A Kafka Connect source connector that generates data for tests

Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink

Export events from Zeebe to Kafka

Components for building stream loaders from Kafka to arbitrary storages

Utility tool for managing kafka

Spark 2.x 案例操作：Scala版本与 Java1.8lambda版代码示例。涵盖Spark核心技术操作SparkCore、SparkSql、SparkStreaming。同时提供了Spark高级性能优化、序列化...

Sandwich Daemon is the middle man between discord and your microserviced bot. Handles gateway, state and provides a dashboard.

Terraform module which creates Msk Kafka Cluster on AWS

ARM64 compatible images of confluent-platform

基于Spark的实时推荐系统,使用MovieLens作为测试数据集

Awesome information for using Kafka and Confluent Platform in Clojure.

Kafka REST proxy

Real-time vehicle telematics analytics demo using OmniSci

RELK -- The Research Elastic Stack (Kafka, Beats, Zookeeper, Logstash, ElasticSearch, Kibana, Spark, & Jupyter -- All in Docker)

A Kafka adapter for the php-pubsub package

Internet of Things platform for device management, data collection, analytics and visualization and more.

A collection of runnable and self-contained examples from various akka-streams and Alpakka docs, tutorials and blogs

🥑 Kafka connect sink connector for ArangoDB

An example system that captures a large stream of product usage data, or events, and provides both real-time data visualization and SQL-based data ana...

优秀且开源的基础系统服务整理，包括 Hadoop、消息队列、流计算、服务发现与配置、NoSQL、监控、容器、质量管理等领域的热门系统

Rust Kafka HTTP proxy

Developer Workshops related to the Java development on OpenShift

GraphQL layer to publish and consume events from any message broker

streaming data pipeline platform

log4net appender to Kafka and provide logstash json_event PatternLayout

Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde

Log Driver for Moby which forwards logs to Kafka

☎️kafka plugin for eggjs

Kafka, Debezium and Fuse demonstration based on Chuck Norris movies!