apache-kafka-consumer

Modern and performant Kafka client library for Ruby based on librdkafka

Experimental DuckDB extension for reading Apache Kafka topics and inspecting cluster metadata from SQL.

MCP Server for Apache Kafka

Are you tired of collecting Apache Kafka client metrics using JMX? Worse, you even can't do that? Here is a solution. With the KIP-714, you can collect client metrics from the Kafka broker using OpenTelemetry.

Streaming data pipeline that learns from 47GB of historical eBird observations to generate synthetic bird sightings and detect anomalies using Java, Kafka Streams, and Docker.

Progetto di Simulazione di Cattura da un DB Legacy

Mail delivery service with Apache Kafka and Spring boot.

A curated list of awesome Kafka tools and resources.

Implementation of Apache kafka with Spring boot Consumer and Producer application.

A microservices-based Patient Management System built with Spring Boot, featuring inter-service communication via gRPC & Apache Kafka, JWT authentication, Spring Cloud API Gateway, and Docker containerization.

A read-only Kafka CLI tool for capturing cluster state and detecting drift during incidents.

Production-style Apache Kafka multi-region disaster recovery (DR) and high availability (HA) setup using multi-broker clusters, MirrorMaker2 replication, failover/fallback architecture, PostgreSQL, Prometheus, Grafana, and Kafka UI with Docker Compose.

Learn about Kafka

This project integrates stock market analysis, tweet sentiment analysis, and stock price forecasting using ARIMA and GRU. It fetches data from MySQL, MongoDB, and streams via Kafka. YCSB benchmarks MySQL and MongoDB performance. The system predicts stock prices and analyzes public sentiment.

This application developed using Spring Boot, Java19, MySQL, Spring Data JPA, Maven, Lombok. This demo Spring Boot application is a updated version that provides high structure of Kafka messaging framework implementation with the Producer and Consumer configuration with the Kafka Template, Kafka Annotations.

Kafka program to ingest wikimedia's real time streaming data into MySQL for data analytics

A Spring boot application leveraging Apache Kafka to demonstrate the implementation of multiple producers and consumers for both String and JSON messages. The application utilizes MySQL as the underlying database to store efficiently processed and consumed messages.

Kafka retry and DLQ demo using native clients, showcasing manual error handling without frameworks.

.NET 8 Microservices Architecture with CQRS and Event Sourcing supported by Kafka. Strictly CQRS pattern, Mediator pattern from scratch, DDD concepts, Event Store with MongoDB, Database-Per-Service Pattern, Replaying events from store implementation.