Igor De SouzaEvent Streaming from a Galaxy Far, Far Away
https://topicigor.substack.com/p/event-streaming-from-a-galaxy-far
MCP-kafka
An open-source MCP (Model Context Protocol) server for Apache Kafka, built with Quarkus. Enables AI assistants like Claude, Goose, and Gemini to interact with Kafka clusters and Schema Registry.
Kafka Pub/Sub with Spring Boot (Step-by-Step)
A minimal Kafka-based Pub/Sub system built using Spring Boot + Docker + Kafka UI to understand how event-driven systems work in real-world microservices.
https://github.com/indrajitruidas1225/pub-sub-demo-kafka-springboot
GitHub - indrajitruidas1225/pub-sub-demo-kafka-springboot: This project demonstrates a minimal event-driven architecture using Spring Boot and Apache Kafka. It shows how a producer publishes messages to a Kafka topic and how consumers subscribe and process those messages asynchronously. Kafka UI is included to visually observe topics and message flow in real time, making it ideal for learning and debugging
This project demonstrates a minimal event-driven architecture using Spring Boot and Apache Kafka. It shows how a producer publishes messages to a Kafka topic and how consumers subscribe and process...
Real-Time Stock Market Data Pipeline
A high-frequency financial data engineering project. This system streams live trade data from WebSockets into a KRaft cluster, providing real-time portfolio valuation and automated email alerts.
https://github.com/Srini1024/kafka-stock-prices-alert-system
GitHub - Srini1024/kafka-stock-prices-alert-system: Real-time stock market data pipeline using Python, Kafka, and WebSockets. Features live portfolio tracking and automated Gmail alerts
Real-time stock market data pipeline using Python, Kafka, and WebSockets. Features live portfolio tracking and automated Gmail alerts - Srini1024/kafka-stock-prices-alert-system
InfoQ#Confluent introduces a new approach in #ApacheKafka that moves schema IDs from message payloads to record headers.
✅ Simplify schema governance & evolution.
✅ Improve compatibility across serialization formats
✅ Reduce coupling between data & metadata in event-driven architectures
Read the deep dive on #InfoQ ⇨ https://bit.ly/4tF7Fot
#ML #EventStreamProcessing #ProtocolBuffers #DataPipelines #DataAnalytics
Can Kafka Queues Make Consumers Faster?
https://www.streamingdata.tech/p/can-kafka-queues-make-consumers-faster
What’s new in Spring for Apache Kafka 4? by Tim van Baarsen @ Spring I/O 2026
What’s new in Spring for Apache Kafka 4? by Tim van Baarsen @ Spring I/O 2026
Stateful Kafka Streams Processors: Reducing Rebalancing - Lessons Learned
https://lukastymo.com/posts/028-stateful-kafka-stream-processors
Stateful Kafka Streams Processors: Reducing Rebalancing - Lessons Learned
Stateful Kafka Streams on Kubernetes need configuration to stay stable during rolling updates without causing lag. If your processor must be fast, runs on few partitions, and short lag matters, the defaults are not enough. Enable static membership with a timeout based on the worst-case duration of your rolling updates.
Awesome Kafka
A curated list of awesome Apache Kafka resources, tools, libraries, and applications.
Sensor City Traffic Demo — Kafka on Kubernetes