Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.
-
Updated
Aug 29, 2025 - Kotlin
Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.
Client tool that exports the consumer lag of Kafka consumer groups to Prometheus or your terminal
This projects gives Kotlin bindings and several extensions for Apache Kafka Clients.
Ktor web server with Kakfa producer and consumer
Kafka client using kotlin flow and coroutines
🚕 kLyfft app - lyft-like event-driven application
Examples of retry mechanisms for spring-kafka consumer
A small example of Kafka producer and consumer, based on Allura Apache Kafka Formation
Kafka producer consumer app in kotlin
🌰 Useful examples for kafka
HoBom's internal backend
Proof of concept project on implementing both near-real-time & batched search agent functionality
Aggregate data from both kafka topic (Kafka Streams) and static file.
A PoC app built-in Kotlin with Spring Boot to study Apache Kafka.
Kafka on the Shore
Microservice responsible to store the health professionals movements within the Operating Block.
A demonstration project showcasing Kafka integration with Spring Boot. This repo provides examples of Kafka producers and consumers, Spring Boot configuration, and message processing patterns.
Add a description, image, and links to the kafka-consumer topic page so that developers can more easily learn about it.
To associate your repository with the kafka-consumer topic, visit your repo's landing page and select "manage topics."