kafka

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

Fast Data Cluster (Apache Cassandra, Kafka, Spark, Flink, YARN and HDFS with Vagrant and VirtualBox)

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

Apache Camel, Kafka Component

A modular & idiomatic Kafka client in Go

Archive and manage your Sony RAW images

Tool that providing ability to access kafka data - query items in topics and kafka metadata

:whale: Build & Deploy the containerized Dev & Prod Env

Edge-X S3 API, mount S3 bucket for full POSIX read/write access

A set of Clojure libraries to work with Apache Kafka (producer, consumer, rebalancing, administration, and validation).

A tutorial on building a real-time data streaming application pipeline with Apache Kafka🔥🔥🔥

hadoop flume hbase kafka storm；读取kafka数据=》storm实时处理（分割字符，统计字符）=》写入hdfs

Monitoring tool to measure flow throughput of data sources and processing components that are part of Data Ingestion and ETL pipelines.

Java后端学习笔记。包括Linux、maven、git、互联网架构、大数据体系等

Stream with Spring Boot Reactive + Kafka + Server Sent Event + Cassandra.