kafka

Utility to help with draining nodes running Strimzi-managed Apache Kafka® or ZooKeeper® pods

Java (Spring) microservices example with Kafka and saga pattern

streaming data pipeline platform

Reactive Streams framework with support for at-least-once processing

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

🥑 Kafka connect sink connector for ArangoDB

GraphQL layer to publish and consume events from any message broker

Developer Workshops related to the Java development on OpenShift

Rust Kafka HTTP proxy

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...

Kafka Connect connector that reads JSON data from Apache Kafka and send JSON record to Another Kafka topic.

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...

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

Kafka streaming with Spark and Flink example

Debezium MongoDB starter

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...

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

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

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

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

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

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

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

Python Logging Handler for Kafka

Spring Boot microservice providing generic Kafka message retry capability

An interactive CLI tool for managing Kafka topics

Plumber, for your dirtiest Kafka streaming jobs

Spring boot & Spring Cloud Kafka support

kafka .net core library

Pulsar IO Kafka Connector

Self-contained demo using Kafka, Materialize and Metabase to check what's streaming on Twitch. All you need is Docker and Twitch access tokens! :space...

Power Plant simulator service that can ramp up and down power producing units

Saga Pattern implementations

日志收集解决方案，动态管理、轻量级日志收集客户端