kafka

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

The most simple way to test Kafka based applications or micro-services e.g. Read/Write during HBase/Hadoop or other Data Ingestion Pipe Lines

A kafka development cluster using docker

Red Hat CodeReady Containers (Minishift equivalent for OpenShift 4.2 or newer) - step-by-step demo guides

Kafka connect Elastic sink connector, with just in time index/delete behaviour.

Kafka Streams based microservice

Docker build project to setup a lightweight hadoop cluster containing hadoop, pig, zookeeper, hbase, phoenix, storm, kafka, kafka manager

Saga Pattern implementations

Arquitectura simple de propósito general para el procesamiento en tiempo real y batch de lecturas de sensor de temperatura sobre arduino.

A beautiful web app to operate kafka

Python Logging Handler for Kafka

Spring Boot microservice providing generic Kafka message retry capability

Here we created some projects using Kafka, AI , Data virtualization and Machine Learning

An interactive CLI tool for managing Kafka topics

Plumber, for your dirtiest Kafka streaming jobs