kafka

The OEE-Designer is the build time environment for OEE applications.

A CLI and Go client for Kafka Schema Registry. This repository is deprecated and no longer maintained.

Kafka Connect FileSystem Connector

Simple URL shortener built with Fastify. Uses PostgreSQL, Redis, and Kafka.

Event sourcing journal implementation using Kafka as main storage

This is an example application to show howto use Spring Boot 4, Angular 22, Kafka with Streams and Mongodb with the reactive features of Spring in a c...

A convenient Elixir library to work with Avro messages, schemas and Confluent® Schema Registry

Management and automation platform for Stateful Distributed Systems

Aiven's JDBC Sink and Source Connectors for Apache Kafka®

Ballerina Kafka Module.

A new type of asynchronous database combining the concepts of distributed databases and blockchain

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink b...

A simple go application to test whether a port or a service is ready or not

Seal Your System's Boundaries

L7 data-layer proxy

Clojure client for Kafka

Superman是什么：构建Java Android 高级开发技术的知识体系，从基础不断打怪升级成为超人之路（更新中.......）

A Terraform provider for managing resource in confluent.cloud

This repository is for the Apache Kafka Course

JUnit rule for spinning up a Kafka broker

关于kafka的一些相关使用示例代码。

A Queue Abstraction Layer for Rust (Redis, RabbitMQ, SQS, etc.)

Simple examle for Spark Streaming over Kafka topic

ksqlDb.RestApi.Client is a C# LINQ-enabled client API for issuing and consuming ksqlDB push and pull queries and executing statements.

Microservices data exchange with change data capture and outbox pattern.

Apache Kafka® extension for Visual Studio Code

Template to quickstart streaming analytics using Apache Kafka for ingestion, QuestDB for time-series storage and analytics, Grafana for near real-time...

SQL Server Change Stream sample using Debezium

Machine learning around business processes

A high-throughput, consistent ticket reservation system that can process 83000+ reservations per second

Clojure transducers interface to Kafka Streams

golang基础知识及实现，偏重于数据结构。另外包含web开源项目(中间件)的日常使用

pastaʃ'ʃ = Spaghetti I/O Event Data Processing, Interpolation, Correlation and beyond :spaghetti:

Namespaces for Apache Kafka.

Functional programming with Kafka and Scala

HTTP based Kafka Client for Serverless and Edge Functions

The goal of this project is to implement a "News" processing pipeline composed of five Spring Boot applications: producer-api, categorizer-service, co...

Rust based DuckDB Server with 1st class Postgres interface for BI Tools like Power BI and Tableau. Streaming interfaces like Web, Kafka, and FlightSQL...

强烈推荐🔥🔥🔥 🦜麻雀虽小五脏俱全🦜 🏄🏻‍♂️ 享受环境一切顺利的快乐🏄🏻‍♂️ 🌍所有环境统一规范管理🌍📦超强环境打包管理器📦🔨 一键快速启动多个服务环境的...

A full ecosystem that is built around kafka powered by golang

Zeek IDS Dockerfile

使 scrapy 开发不用在意 item，pipeline，middleware 等通用场景下模块的编写，解放开发者的双手。

A Mysql data to file/elasticsearch/kafka/redis/redis-cluster/mongodb(audit and normal)/TiDB/postgresql with binlog tool.

Go-CQRS-EventSourcing-Microservice

This project walks through how you can create recommendations using Apache Spark machine learning. There are a number of jupyter notebooks that you ca...

大数据组件 All-in-One 的 Dockerfile

Simple Event Driven Microservices with Spring Cloud Stream

Kafka Connect for Zeebe.io