kafka

Ari-proxy connects Asterisk, an open source communication server, to the Apache Kafka distributed streaming platform.

Today I Learned

Demo to go with https://eggybits.com/posts/events-first 🍳🥞

Utility to help with draining nodes running Strimzi-managed Apache Kafka® or ZooKeeper® pods

A Declarative framework for Building, Maintaining, and Analyzing Graph Data

Hot-swap API endpoints and stream processors using Clojure and Dataworks

Materials (slides and code) for Kafka and Kafka Streams Workshops

Make OpenTelemetry works on .NET Core with features such as tracing, logs and metrics on multiple protocols like HTTP/gRPC/UDP/TCP...

基于大数据的图书推荐系统

Open Policy Agent (OPA) plug-in for Kafka authorization

Kafka Flow Retry Patterns Extensions

Bellamy Book is a modern social network platform: posts, stories, messaging, video calls, blogs, search, and an admin panel. This repository is the se...

Implementing an Event Sourcing/CQRS microservices with Apache Kafka

Amplicode базируется на привычных для разработчиков средах разработки IntelliJ IDEA и VS Code и предоставляет инструменты максимально комфортной и эфф...

Spark structured streaming with Kafka data source and writing to Cassandra

Event-Driven microservices with Kafka Streams

Example app and service templates `dotnet new -i Equinox.Templates; dotnet new eqx*/pro*` https://github.com/jet/equinox https://github.com/jet/FsCode...

systemd journald to aws_cloudwatch, elasticsearch, google cloud logging, kafka, rsyslog or logplex log sender

Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala

A series of distributed components for Scrapy. Including RabbitMQ-based components, Kafka-based components, and RedisBloom-based components for Scrapy...

Kafka Connect Transform to copy Avro schemas between Schema Registries

A library to build streaming applications that consume from and produce to Kafka.

Example of a node microservice with NestJS + Prisma + Clean Architecture (notifications API)

Enterprise-grade UI and API for Apache Kafka®. Official release artifacts and Docker images for Kpow.

JDK 11 examples and demo projects.

Plugin for support Kafka in Gatling

基于Spark2.2新闻网大数据实时系统项目

An opinionated micro-services framework for TypeScript

Terraform module to create AWS MSK (Managed Streaming for Kafka) resources 🇺🇦

Framework agnostic message queue

create an open sourced option for setting up a unified name space for IIOT transformation.

FastStream - Taskiq integration to provide you with a great scheduling feature

[ 开箱即用 ] 一款基于 .NET 10 WPF 架构的工业物联网插件化数据采集转发工具（OPC[UA/DA]/Modbus/数据库/非标数据/大部分PLC/Mqtt/Kafka/NetMQ/Netty/RabbitMQ...

ChanBroker, a Broker for goroutine, is simliar to kafka

An eventual consistency framework based on Event Sourcing and CQRS on top of light-4j and Kafka

:horse: Pure Pony Kafka client

A tool for developing and testing ETL and ELT processes for automating the capture, delivery and processing of information in data warehouses on the M...

Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.

Asp.Net Core microservices that communicate asynchronous through Kafka message broker.

Stream database events from PostgreSQL to Kafka

producer and consumer FastAPI endpoints to handle incoming geo data

Project for real-time anomaly detection using Kafka and python

Python Django as Producer and Consumer using Apache Kafka for content queue and Celery for task queue

Code base for Spring Boot projects with MySQL, MongoDB, Redis and Kafka

Scalable data processing pipelines in JavaScript

Databases: Concepts, commands, codes, interview questions and more...

Example Scala API to bootstrap new projects

PHP Kafka producer / consumer library with PHP Avro support, based on php-rdkafka