kafka

Rdkafka extension stubs for your IDE. Always compatibile with the latest php-rdkafka version.

An example Event-Driven application in Go built with Watermill library.

支持MySQL、MongoDB数据变更订阅分发

Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

Kafka 0.8.0 broker implementation on top of Cloudflare Workers

A desktop client for Apache Kafka.

Apache Kafka on Docker

Fully reproducible, Dockerized, step-by-step, demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres. Detailed blog post published...

Big Data Toolkit for the JVM

Syslog Collector written in Go, streams to Kafka 0.8

Springboot、SpringCloud各种常用框架使用案例，完善的文档，致力于让开发者快速搭建基础环境并让应用跑起来，并提供丰富的使用示例供使用者参考，快速上手。

Samsara is a real-time analytics platform

Event-Driven Architecture for a microservices-based system with a clean architecture + Domain Driven Design (DDD) + CQRS pattern + Saga pattern + Outb...

A real-time reddit data streaming pipeline for sentiment analysis of various subreddits

Get data from API, run a scheduled script with Airflow, send data to Kafka and consume with Spark, then write to Cassandra

Cross-vendor normalisation for network syslog messages, following the OpenConfig and IETF YANG models

Swiftly build and enhance your Kafka Streams applications.

Export network flows from Kafka to Prometheus

最好的大数据项目。《Titan数据运营系统》，本项目是一个全栈闭环系统，我们有用作数据可视化的web系统，然后用flume-kafaka-flume进行日志的读取，在hive设计数...

The goal of this project is to compare some Java Microservice Frameworks like: Quarkus, Micronaut and Spring Boot. For it, we will implement applicati...

JR: streaming quality random data from the command line

Java Spring Boot microservices stack (PostgreSQL, Kafka, Elasticsearch, Kibana, Fluentd, JWT Auth, Swagger) — easily build & run all services in two c...

Cloud and on-premises automation for Kubernetes centered industrial grade solutions.

MemQ is an efficient, scalable cloud native PubSub system

Tangseng search engine including full text search and vector search base on golang. 基于go语言的搜索引擎，信息检索系统

Nyc_Taxi_Data_Pipeline - DE Project

Distributed immutable data store with strong encryption and authentication

Bireme is an incremental synchronization tool for the Greenplum / HashData data warehouse

A Clojure DSL for Kafka Streams

Keycloak module to produce events to kafka

INGenious Playwright Studio

Ansible role for installing and configuring Apache Kafka on RedHat and Debian platforms.

Mockingbird is a mock streaming data generator

Java-Spring-CRQS-Eventsourcing-Microservice

Metronome is a distributed and fault-tolerant event scheduler

Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.

史上最轻便好用的kafka 可视化图形界面客户端工具，可以生产消费消息，管理topic、group、集群。支持管理多个kafka环境。同时支持zookeeper redis 图形化界面操...

This is Node.js server tidy template / boilerplate with Express (with asyncified handlers, custom error handler) framework and MongoDb. The server us...

Solana geyser plugin implementing a Kafka publisher

eCommerce application is a platform where customers can find products, shop around using a cart, check out the products and initiate payments. It is u...

Integration that uses Home Assistant Kafka integration for creating home automations in .NET and C#

OpenTracing Instrumentation for Apache Kafka Client

Core for OPEX exchange, Open Source Cryptocurrency Exchange

My own version of r/place, done in a weekend

Bro IDS Dockerfile

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

ORAcle database CDC (Change Data Capture)

Open Source Customer Engagement Platform (Customer.io Alternative)

equivalent to kafka-connect :wrench: for nodejs :sparkles::turtle::rocket::sparkles:

Полнофункциональный адаптер для 1С