इस प्रोजेक्ट के बारे में

RisingWave एक इवेंट स्ट्रीमिंग प्लेटफॉर्म है जो डेटा इंजेक्शन, इंक्रीमेंटल प्रोसेसिंग और लो-लेटेंसी सर्विंग को एकीकृत करके पारंपरिक जटिल स्टैक (जैसे Debezium, Kafka और Flink) की जगह लेता है। इसे रियल-टाइम एप्लिकेशन और AI एजेंटों के लिए ताज़ा, क्वेरी करने योग्य डेटा प्रदान करने के लिए डिज़ाइन किया गया है। मुख्य क्षमताओं में शामिल हैं: - **Multi-source Ingestion**: वेबहुक्स, डेटाबेस (PostgreSQL, MySQL) से नेटिव CDC, इवेंट स्ट्रीम्स (Kafka, Pulsar, Kinesis), और S3 से ऐतिहासिक बैच डेटा का समर्थन करता है। - **Incremental Processing**: निरंतर गणना करने के लिए materialized views का उपयोग करता है, जिससे 100ms से कम का एंड-टू-एंड डेटा फ्रेशनेस सुनिश्चित होता है। - **Low-Latency Serving**: 10-20 ms p99 लेटेंसी के साथ SQL क्वेरीज़ को सर्व करने के लिए एक आंतरिक row store में परिणाम बनाए रखता है। - **Open Storage Integration**: दीर्घकालिक प्रतिधारण और विश्लेषणात्मक पहुंच के लिए Apache Iceberg टेबल में लिखता है, और वेक्टरकृत क्वेरी निष्पादन के लिए Apache DataFusion का उपयोग करता है। - **Cost-Efficient Architecture**: लागत कम करने और इलास्टिक स्केलिंग सक्षम करने के लिए आंतरिक स्थिति और materialized views को ऑब्जेक्ट स्टोरेज (S3) में स्टोर करता है, जिसमें प्रदर्शन के लिए एक वैकल्पिक डिस्क कैश होता है। - **Compatibility**: PostgreSQL वायर प्रोटोकॉल के माध्यम से कनेक्ट होता है और AI एजेंट एकीकरण के लिए एक MCP सर्वर, CLI और Skills प्रदान करता है। सामान्य उपयोग के मामलों में रियल-टाइम मॉनिटरिंग और अलर्टिंग, ML के लिए फीचर स्टोर, लाइव डैशबोर्ड, रियल-टाइम डेटा एनरिचमेंट और स्ट्रीमिंग लेकहाउस शामिल हैं।