3 रिपॉजिटरी
Awesome GitHub RepositoriesOffset Commit Managers
Manually commit message offsets after processing to control exactly when progress is recorded in stream consumption.
Distinguishing note: No candidate covers manual offset committing in stream processing; closest candidates relate to VCS commit messages.
Explore 3 awesome GitHub repositories matching data & databases · Offset Commit Managers. Refine with filters or upvote what's useful.
Awesome Offset Commit Managers GitHub Repositories
AI के साथ बेहतरीन रिपॉजिटरी खोजें।हम AI का उपयोग करके सबसे सटीक रिपॉजिटरी खोजेंगे।
- segmentio/kafka-go
segmentio/kafka-go
8,581GitHub पर देखेंKafka library in Go
Provides explicit offset commit control for Kafka consumer progress tracking.
Goconsumergogolang - tulios/kafkajs
tulios/kafkajs
3,997GitHub पर देखेंKafkaJS Apache Kafka के लिए एक शुद्ध JavaScript क्लाइंट है, जो नेटिव डिपेंडेंसी या बाहरी ऐडऑन की आवश्यकता के बिना Kafka क्लस्टर से संदेश उत्पन्न करने और उपभोग करने के लिए आवश्यक टूल प्रदान करता है। यह वितरित संदेश प्रसंस्करण और रीयल-टाइम इवेंट स्ट्रीमिंग में संलग्न होने के लिए Node.js एप्लिकेशन के लिए एक व्यापक एकीकरण लाइब्रेरी के रूप में कार्य करता है। यह प्रोजेक्ट Kafka वायर प्रोटोकॉल के अपने नेटिव कार्यान्वयन द्वारा प्रतिष्ठित है, जो C++ डिपेंडेंसी से बचता है। इसमें SSL, TLS, और SASL प्रमाणीकरण का समर्थन करने वाला एक सुरक्षा क्लाइंट शामिल है, साथ ही ट्रांजेक्शनल क्षमताएं जो परमाणु संदेश भेजने और बिल्कुल-एक-बार (exactly-once) प्रसंस्करण सुनिश्चित करने के लिए लिंक्ड ऑफ़सेट प्रतिबद्धताओं की अनुमति देती हैं। यह लाइब्रेरी परिचालन क्षेत्रों की एक विस्तृत श्रृंखला को कवर करती है, जिसमें टॉपिक्स और कंज्यूमर ग्रुप्स को प्रबंधित करने के लिए पूर्ण क्लस्टर प्रशासन, उन्नत विभाजन रूटिंग और असाइनमेंट रणनीतियाँ, और इवेंट-संचालित निगरानी के माध्यम से व्यापक टेलीमेट्री शामिल है। यह विलंबता को अनुकूलित करने के लिए एक्सपोनेंशियल बैकऑफ़ रिट्रीज़ और रैक-जागरूक डेटा फ़ेचिंग जैसे नेटवर्क विश्वसनीयता पैटर्न भी लागू करती है।
Records processed message positions based on time intervals, message counts, or manual triggers.
JavaScriptkafkakafka-clientnodejs - linkedin/burrow
linkedin/Burrow
3,954GitHub पर देखेंBurrow is a monitoring and alerting service for Kafka clusters. It tracks consumer group lag by evaluating committed offsets and identifying the gap between produced and consumed messages. The system calculates processing delays using a sliding-window offset evaluation and monitors overall cluster health. When consumer group conditions meet predefined thresholds, it triggers notifications to external services via email or webhooks. The service provides HTTP endpoints for querying broker information and consumer group status, allowing external tools to poll for system health and performance m
Calculates consumer lag by tracking committed offsets over a specific time interval to detect processing delays.
Go
