kafka

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

Inspr is an agnostic application mesh for simpler, faster, and securer development of distributed applications (dApps).

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

Learn the basics of Apache Kafka® from leaders in the Kafka community with these video courses covering the Kafka ecosystem and hands-on exercises.

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

Example Scala API to bootstrap new projects

AsyncAPI Event Gateway

Thin Scala wrapper for the Kafka Streams API

💥 A simple multi-purpose connection pool client (Kafka & Hbase & Redis & RMDB & Socket & Http)

Atomic, bite-size, highly-focused interactive tutorials that teach you how to work with Kafka

Klaw, the latest OS tool by Aiven, helps enterprises cope with Apache Kafka(r) topics, schema registry and connectors governance by introducing roles/...

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

DevOps

Ns4Kafka brings namespaces on top of Kafka brokers, Kafka Connect and Schema Registry.

Apache Kafka Connect sink connector for HTTP

C++ Kafka coroutine library using Quantum dispatcher and wrapping CppKafka

An umbrella project for multiple implementations of model serving

A Spring Boot Camel boilerplate that aims to consume events from Apache Kafka, process it and send to a PostgreSQL database.

App Server independent JCA Connectors for Java EE 8+ that connect to Cloud Services.

An open-source visualization tool for monitoring Kafka cluster metrics

springboot大杂烩

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

Kafka Flow Retry Patterns Extensions

The extension adds messaging capabilities to Magento2 application.

Distributed crawling/scraping, Kafka And Redis based components for Scrapy

EMQX plugin Kafka bridge send messgaes from broker to kafka

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernet...

Redis Kafka Streams State Store

便于使用的canal-spring-boot-starter客户端

Provides consistent standard use of common components of the .Net Core language

kdb+ to Apache Kafka adapter, for pub/sub

Java相关框架, java 基础, Spring, mybsatis ,SpringBoot ,分布式,微服务

Scalable Kubernetes logging stack with Opensearch

This project uses Apache Flink as a stream engine that consumes data from the File system or Kafka brokers and exposes metrics using Prometheus and Gr...

Aiven's collection of Single Message Transformations (SMTs) for Apache Kafka Connect

IoT Transportation demo using Red Hat OpenShift and Middleware technologies

SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失

A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.

大数据学习，主要涉及Kafka、ZooKeeper、Hive、HBase、Spark

kafka connector 插件，支持输入 mysql binlog 和 json 格式写入ClickHouse。持续更新

:credit_card:优惠券系统后台实现

Near real time cloud native data pipeline in AWS (CDC+Sink). Hosts code for RedshiftSink. RDS to RedshiftSink Pipeline with masking and reloading supp...

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

"eCupcakesFactoryOnContainers" is based on a simplified "Microservices" architecture and docker containers. Core intent of this reference application...

Aiven's S3 Sink Connector for Apache Kafka®

基于SSM + Spring Boot + Thymeleaf开发的论坛社区网站

SpringBoot商城系统Demo，主要功能：提供了商城系统的后端Api，不包含前端页面，体现了前后端解耦分离的思想。实现了商品，购物车，订单系统，单点登录系统等4个...

Kubernetes Kafka Overview, Burrow consumer lag stats, Kafka disk usage

📕 Kafka Connect source and sink connector for Redis

Kafka Pub/Sub for the Watermill project.