kafka

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

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

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

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

Seal Your System's Boundaries

End to end data engineering project with kafka, airflow, spark, postgres and docker.

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

Clojure client for Kafka

A Terraform provider for managing resource in confluent.cloud

L7 data-layer proxy

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

This repository is for the Apache Kafka Course

Simple examle for Spark Streaming over Kafka topic

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

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.

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

JUnit rule for spinning up a Kafka broker

SQL Server Change Stream sample using Debezium

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

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

Apache Kafka® extension for Visual Studio Code

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

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

Machine learning around business processes

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

Clojure transducers interface to Kafka Streams

HTTP based Kafka Client for Serverless and Edge Functions

Zeek IDS Dockerfile

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

Namespaces for Apache Kafka.

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

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

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

Functional programming with Kafka and Scala

A full ecosystem that is built around kafka powered by golang

Simple Event Driven Microservices with Spring Cloud Stream

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

Kafka Connect for Zeebe.io

Go-CQRS-EventSourcing-Microservice

Typescript API that implements CQRS & Event Sourcing

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

Dumps state of Storm Kafka consumers

Replicate and sync Kafka topics between clusters in realtime. Supports topic re-mapping, healthchecks, and hot failovers for high availability.

Kafta is a command line for managing Kafka clusters

Integration between Micronaut and Apache Kafka

kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)

CloudNative Microservices, Container, Orchestators, Service Mesh, CI/CD, IaC, GitOps, Monitoring. Learn, explore, design and develop +20 Hands-on real...