kafka

OCaml bindings for Kafka

A Kafka Connect sink plugin to invoke AWS Lambda functions

Aiven's GCS Sink Connector for Apache Kafka®

FlinkTutorial 专注大数据Flink流试处理技术。从基础入门、概念、原理、实战、性能调优、源码解析等内容，使用Java开发，同时含有Scala部分核心代码。欢迎关注我...

The Internals of Apache Kafka

scheduler for kafka messages

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

Sample Spring Cloud microservices e-shop.

Kalium: a reactive framework for micro-services

Yet another Web UI for KSQL

:seedling: Simple Microservice Architecture based on Sagas and CQRS patterns

Final Project for IoT: Big Data Processing and Analytics class. Analyzing U.S nationwide temperature from IoT sensors in real-time

Apache Camel Kafka Connector Examples

Columbia Image and Face Search tool for MEMEX

:baseball: Streaming left joins in Kafka for change data capture

基于utgard的OPC DA客户端

Client tool that exports the consumer lag of Kafka consumer groups to Prometheus or your terminal

HTTP based Kafka Client for Serverless and Edge Functions

Kafka Development Tool

Very simplified shop sales system made in a microservices architecture using quarkus

This repository contains the code base for the Open Stream Processing Benchmark.

ansible playbook to deploy cloudera hadoop components to the cluster

How to build your first Spark application with MLlib, StructuredStreaming, GraphFrames, Datasets and so on? Answer is here!

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

Stream database events from PostgreSQL to Kafka

E-Commerce API Made With NodeJs,Typescript,PostgreSQL,Redis And Kafka

Support for generating modern platforms dynamically with services such as Kafka, Spark, Streamsets, HDFS, ....

An opinionated micro-services framework for TypeScript

A replica of online travel booking site KAYAK(www.kayak.com) for cmpe-273. Visit ->

Event-Driven Tutorial for Distributed Data with CQRS and Event Sourcing

KafkaPeek is an open-source application designed to help developers visualize, monitor, and stay up-to-date on their Kafka deployments

Connect to CloudKarafka using Java and SASL/SCRAM-authentication

A library provides consumer/producer to work with kafka, avro and schema registry

SWIR - Sidecar Written In Rust

This is the central repository for all the materials related to Apache Kafka For Absolute Beginners Course by Prashant Pandey.

An Apache Kafka cluster size calculator

Ansible playbooks for the Confluent Platform

Kafka consumer lag monitor

A Kafka Connect Source for FTP servers - Monitors files on an FTP server and feeds changes into Kafka

An avro converter for Kafka Connect without a Schema Registry

Kafka End to End Encryption

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.

Karafka WaterDrop and Sidekiq backend example application

CMAK (prev. Kafka Manager) for Kubernetes

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

Open source, accessibility driven web application for monitoring and alerting Apache Kafka broker metrics

Want to work with us? Here is a mini-coding challenge you can try :)

Enables you to start and stop a fully-fledged embedded Kafka cluster from within JUnit and provides a rich set of convenient accessors and fault injec...

AsyncAPI Event Gateway