kafka

Spring template for a REST service designed with Hexagonal architecture

**Unofficial / Community** Kafka Connect MongoDB Sink Connector -> integrated 2019 into the official MongoDB Kafka Connector here: https://www.mongodb...

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this librar...

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

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

A desktop client for Apache Kafka.

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

Nyc_Taxi_Data_Pipeline - DE Project

[Deprecated] Load data from Kafka to any data warehouse. BQ sink is being supported in Firehose now. https://github.com/odpf/firehose

Kafka 0.8.0 broker implementation on top of Cloudflare Workers

This project provides Docker compose files to deploy an Apache Kafka platform with a monitoring stack using Prometheus and Grafana

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

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

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

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

Apache Kafka on Docker

Syslog Collector written in Go, streams to Kafka 0.8

Swiftly build and enhance your Kafka Streams applications.

Export network flows from Kafka to Prometheus

Samsara is a real-time analytics platform

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

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

Big Data Toolkit for the JVM

🐮 Build distributed, event-driven agents

INGenious Playwright Studio

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

JR: streaming quality random data from the command line

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

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

Keycloak module to produce events to kafka

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

Mockingbird is a mock streaming data generator

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

MemQ is an efficient, scalable cloud native PubSub system

Distributed immutable data store with strong encryption and authentication

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

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

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

A Clojure DSL for Kafka Streams

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

Java-Spring-CRQS-Eventsourcing-Microservice

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

Metronome is a distributed and fault-tolerant event scheduler

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

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

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

Core for OPEX exchange, Open Source Cryptocurrency Exchange

📈 A scalable, production-ready data pipeline for real-time streaming & batch processing, integrating Kafka, Spark, Airflow, AWS, Kubernetes, and MLfl...

Repid is a simple, fast, and extensible async task queue framework, with built-in AsyncAPI 3.0 schema generation

OpenTracing Instrumentation for Apache Kafka Client