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

Apache Spark and Apache Kafka integration and Spark Analytics over DataFrame.

Learning Apache Kafka

Kafka Producer and Consumer Application with different groups and partition.

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…

Code to generate kafka images in hub.docker.com.

Sample project to start learning with Apache Kafka.

Kafka Docker

Kafka is an event streaming platform.

Kafka Implementation