This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka server running within the context of your tests. No need to stand up an external kafka cluster!
Karafka and WaterDrop example applications
Kafka docker image, ready for k8s and openshift clusters
Python script demonstrating spark streaming and Kafka implementation using an e-commerce website like product recommendation engine based on item-based collaborative filtering. 🐍. 💥
Spring boot kafka application with multiple Producers and multiple Consumers for String data and JSON object
Alternative Server for the Apache Kafka network protocol
Install Apache Kafka on Ubuntu 26.04 using KRaft mode (Kafka 4.x without ZooKeeper) and legacy ZooKeeper setup (Kafka 3.x). Complete step-by-step DevOps guide with scripts, testing, and production configuration.
Apache Spark and Apache Kafka integration and Spark Analytics over DataFrame.
Kafka Producer and Consumer Application with different groups and partition.
Sample project to start learning with Apache Kafka.
Learning Apache Kafka
Kafka Implementation
Apache Kafka is a distributed streaming platform that is used for building real-time data pipelines and streaming applications.
Kafka is an event streaming platform.
Code to generate kafka images in hub.docker.com.
This Project is a complete package for multi-threaded ETL--It contains code, that can consume messages from distributed Apache Kafka servers parallelly; Secondly, it has easily adaptable Hibernate interface for database operation; Additionally, It is also configured with Spring, to easily access and manage objects across the application, it also…
Minimal Kafka server implementing the Producer API — no storage included
Add a description, image, and links to the kafka-server topic page so that developers can more easily learn about it.
To associate your repository with the kafka-server topic, visit your repo's landing page and select "manage topics."