kafka

Easy and flexible Kafka Library for Laravel and PHP 7

A Data Mesh prototype built on Confluent Cloud

Лекции по курсу Распределенные Системы Обработки Информации кафедры ИУ7 МГТУ им. Н.Э.Баумана

Prometheus exporter for Kafka consumer group information obtained through `kafka-consumer-groups.sh`.

Interoperable GRPC based publish/subscribe

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

Simple demo implementation of Lambda and Kappa architectures using Python, Docker, Kafka, Spark and Cassandra

Kafka infra as code. Template based Kafka topic/cluster/ACL management

빅데이터 pipeline 구성 요소 기술들에 관한 coding 실습 및 연구

Saga Pattern Showcase - Choreography implementation with quarkus, debezium, elastic search - Orchestrator with ksqlDB

深圳地铁大数据客流分析系统

服务收集app web h5 埋点信息，openresty 接受，推送到kafka

A real-time analytical system for ID-associated data

Personal Book Library Web Project

程序员进阶书籍/视频，持续更新（Programmer Books）

Distributed Streaming with Apache Kafka and Python OpenCV

:gem: nodejs kafka connect connector for MySQL, Postgres, SQLite and MSSQL

Read and process pcap files using this nifty tool

Read Kafka topics with WebSockets

Scalable package delivery logistics simulator built using SingleStore and Vectorized Redpanda

kafka plugin for egg.js

sample spring cloud application that integrates with rabbitmq through spring cloud stream framework as shows how to setup message-driven microservices...

Event sourcing in java with vavr, akka stream and vertx reactive PG driver

Data Analysis Using Hadoop/Spark/Storm/ElasticSearch/MachineLearning etc. This is My Daily Notes/Code/Demo. Don't fork, Just star !

tools for bigData

:boom: :alien: :hotsprings::rocket:Encapsulated spark 与其他组件的结合api，方便使用，例如 es，hbase，kudu，kafka，mq等

A simple Spring Boot app that talks to Kafka using Avro and Schema Registry

Health Check for Apache Kafka

Contract Testing Boilerplate for the microservices developed using Spring Boot and Kafka in a maven multi-module project.

Demo execution of a payment transaction without an atomic commit across 3 partitions.

Joyce is a highly scalable event-driven Cloud Native Data Hub.

Conduktor Gateway is a tool to intercept and then filter and transform requests and responses between clients and Apache Kafka

Analyzes network traffic of HBase RegionServers

Professionally supported Zipkin + OpenTracing driver in C#

Running Top N aggregation using Apache Kafka Streams

JAlgoArena programming contest platform

Denormalize and Index MySQL database with ElasticSearch and Kafka

基于springboot & netty & kafka 实现的消息推送服务

Distributed Message Queue based on Raft

A high-performance Python Kafka client. Efficiently from Kafka to Pandas and back.

netty到底能干什么? 这个项目告诉你, netty什么都能干

Multi docker container images for main Big Data Tools. (Hadoop, Spark, Kafka, HBase, Cassandra, Zookeeper, Zeppelin, Drill, Flink, Hive, Hue, Mesos, ....

This repository contains a sample project that can be used to start off your own source connector for Kafka Connect.

This repository contains a set of examples to be used with Red Hat AMQ messaging suite components.

Kafka Examples focusing on Producer, Consumer, KStreams, KTable, Global KTable using Spring, Kafka Cluster Setup & Monitoring. Implementing Event So...

Spring boot 2 türkçe örnekler

Files needed to try out KSQL Recipes for yourself