kafka

Aiven "getting started" code examples

ksqldb-go client

Code examples for the Pathway programming framework

Produce Kafka messages, consume them and upload into Cassandra, MongoDB.

Example Node.js kafka setup

:beetle: kafka cluster example

🎉 Microservices Observability - Log Aggregation, Distributed Tracking, Metrics

Example Docker Cluster for "Full Stack Monitoring and Notification with Prometheus and Grafana"

와이빅타 엔지니어링팀의 자료를 정리해두는 곳입니다.

Django app demoing a middleware that logs all requests to a Kafka broker. Repository receives only security updates.

☁EventBus on Portable Pub/Sub Components☄

Managed ELKK stack implemented with the AWS CDK

Highly configurable JSON format logging per Location - nginx logging module - aka. kasha 🍲

Stream Processing Made Easy

Kafka Connect Elasticsearch connector

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

MySQL Replicator. Replicates MySQL tables to Kafka and HBase, keeping the data changes history in HBase.

A light Kafka to HDFS/S3 ETL library based on Apache Spark

微服务实践的demo

Reactive data changes from SQL server to .NET clients. SqlTableDependency extensions, Joker.OData, Joker.Redis, Joker.MVVM and ksqlDB LINQ provider

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

Showcases how to build a small Event-sourced application using Spring Boot, Spring Kafka, Apache Avro and Apache Kafka

빅데이터 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

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

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

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

Read Kafka topics with WebSockets

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

Scalable package delivery logistics simulator built using SingleStore and Vectorized Redpanda

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

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