kafka

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

Spring boot & Spring Cloud Kafka support

mysql-time-machine project

kafka .net core library

Pulsar IO Kafka Connector

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)

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

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

:orange_book: json & avro http schema registry backed by Kafka

kafEEne: Kafka + Websocket

OSB Transport for Apache Kafka provides inbound and outbound connectivity with Kafka Clusters.

Kafka Connect for Fluentd

Oh you know, just a coupla, two, tree Kafka Streams in Scala

Receive messages from multiple sources using a centralised delivery pipeline

An Avro SerDe implementation that integrates with the confluent schema registry and serializes and deserializes data according to the defined confluen...

API boilerplate using Python Flask with MongoDB

Kafka Streams demo project containing Derivative Events, the Processor Api and Wall-clock examples

基于springboot+springcloud的学习示例,整合springboot admin2.x,sharding-jdbc,分布式session,kafka,rocketmq,websocket,自定义springboot启动器,springcloud-d...

[WIP] An opinionated framework for building distributed domain driven systems using microservices architecture

日志分析产品，该解决方案整合了filebeat、kafka、logstash、elasticsearch、kibana、grafana、elastalert等开源产品，能够实现海量日志实时分析及错误报警，另...

Tails logs from Kafka and pushes to Grafana Loki in an ordered manner

A slack bot that helps you understand and influence your slack community

Elastic Beat for fetching events from Kafka

Order Management service for the Partial Foods sample

Kafka InfluxDB Metrics Reporter

日志采集工具

Simple, RESTful Log Collector

PoC using scala that defines single-message protobuf schema per Kafka topic

Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.

This is a real-time dashboard example using Spark Streaming and Node.js

Process Kafka streams with Clojure Transducers

esque - an operational kafka tool.

a demo project to Analyze most popular twitter hashtags using Java 8 Spring-Boot Spark Streaming Kafka & Docker Demo.

Netty4长连接网关

A curated re-sources list for awesome Apache Kafka

Limit simultaneous viewing with Apache Kafka & Spring Boot Microservices, Redis