kafka

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

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

WASP is a framework to build complex real time big data applications. It relies on a kind of Kappa/Lambda architecture mainly leveraging Kafka and Spa...

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

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

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

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

Spark 2.x 案例操作：Scala版本与 Java1.8lambda版代码示例。涵盖Spark核心技术操作SparkCore、SparkSql、SparkStreaming。同时提供了Spark高级性能优化、序列化...

Kafka Configs Metrics Exporter for Prometheus

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

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.

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

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.

Let's Learn ksqlDB

Fullstack Example Monorepo with Bazel 🌿

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

event-triggered plugins for airflow

A vault plugin for generating ACLs for dynamic users

Connected scarecrow for smart predator repulsion.