{"repo":"Trendyol/quafka","free":true,"listed":false,"github":"https://github.com/Trendyol/quafka","clone":"git clone https://github.com/Trendyol/quafka.git","description":"Quafka is a non-blocking Kafka client library built on top of the Apache Kafka Java client, designed for Kotlin with first-class coroutine support.","language":"Kotlin","stars":26,"topics":["async","jvm","kafka","kotlin","library","non-blocking","kafka-consumer"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Quafka A non-blocking Kafka client library for Kotlin with first-class coroutine support Features • Getting Started • Examples • Documentation • Contributing --- About Quafka is a non-blocking Kafka client library built on top of the Apache Kafka Java client, designed for Kotlin with first-class coroutine support. It separates polling from processing, preserves per-partition ordering, and provides flexible single and batch message handling, backpressure control, and a fluent, type-safe configuration DSL. Quafka also ships with an extensions module that adds higher-level capabilities like retry orchestration, delayed processing, and a middleware pipeline for consumer logic. Features Core Features - 🚀 Non-Blocking & Coroutine-First - Fully supports Kotlin coroutines, enabling highly efficient, asynchronous operations - Ensures your Kafka client remains responsive and scalable under heavy loads without thread management complexity - 🔄 Separated Polling and Processing Model - Decoupled threading model where polling and processing happen independently - Prevents consumer group rebalancing due to slow processing - Ensures consistent throughput even for long-running tasks - ⚡ Worker per Topic and Partition - Dedicated workers for each topic-partition pair - Sequential processing within a partition for order preservation - Maximum parallelism across partitions for optimal resource utilization - 📦 Batch and Single Message Handling - Seamless support for both batch and individual me","default_branch":null,"files":null,"tree":[],"storefront":"/r/Trendyol","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/Trendyol/quafka/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}