kafka

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!

The demo of using Kafka, Spark, Hive, Cassandra, etc by using Docker. It produces the production ready environment for any kinds of big data project r...

A simple Spring Boot (Java) app which demonstrates Apache Kafka's producer and consumer APIs.

a one-stop repo to lookup for code snippets of core java concepts, sql, data structures as well as big data. It also consists of interview questions a...

Kafka streaming with Spark and Flink example

An app (in progress) for reading and listening to classic and modern literature in more than 100 languages. It also serves as a demo for Jetpack compo...

Built a stream processing data pipeline to get data from disparate systems into a dashboard using Kafka as an intermediary.

A JMeter plug-in that enables you to send test results to a Kafka server

service for sending SMS Messages (Quarkus, Kotlin, postgres, kafka, debezium, docker)

The purpose of this module is to solve the problem of multiple keystores using Spring Boot + Kafka + Schema Registry + SSL and Spring Schema Resgistry...

Debezium MongoDB starter

Go application to capture inserts into PostgreSQL table and produce events to Apache Kafka using replication slot and WAL

Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka

Repository for advanced unit-testing with embedded kafka services

Example of how to create your own custom serializers for Kafka queues including JSON, Smile and Kryo