ওপেন সোর্স। নতুন সম্ভাবনা।

go-kafka হলো একটি Go লাইব্রেরি যা franz-go-কে র‍্যাপ করে Apache Kafka-এর জন্য বাউন্ডেড প্রডিউসার, কনজিউমার, রিপ্লে, ইন্সপেকশন এবং ট্রানজ্যাকশনাল বিল্ডিং ব্লক প্রদান করে।

RisingWave হলো এজেন্টিক AI-এর জন্য ডিজাইন করা একটি ইভেন্ট স্ট্রিমিং প্ল্যাটফর্ম যা ইনজেশন, প্রসেসিং এবং সার্ভিং-কে একটি একক সিস্টেমে একীভূত করে।

ক্যাফকা-সহায়ক ব্রোকার (Redpanda) এবং PySpark Structured Streaming ব্যবহার করে একটি রানলেবল লোকাল রিয়েল-টাইম অ্যানালিটিক্স পাইপলাইন। ক্লিকস্ট্রিম ইভেন্ট সিমুলেট করে, ওয়াটারমার্কিং সহ উইন্ডোয়েড এগ্রিগেশন পরিচালনা করে, সবকিছু docker-compose এর মাধ্যমে।

Watermill হলো একটি Go লাইব্রেরি যা ইভেন্ট-চালিত অ্যাপ্লিকেশন তৈরির জন্য ব্যবহৃত হয়। এটি Kafka, RabbitMQ, NATS, Redis, SQL সহ বিভিন্ন সিস্টেমে পাব/সাব মেসেজিংয়ের জন্য একটি সহজ ইন্টারফেস প্রদান করে।

KEFCore হলো Apache Kafka-এর জন্য একটি Entity Framework Core প্রোভাইডার, যা .NET অ্যাপ্লিকেশনকে Kafka টপিককে একটি বিতরণকৃত ডেটাবেস হিসেবে ব্যবহার করতে দেয়। এটি সম্পূর্ণ LINQ সমর্থন দেয় এবং সাধারণ EF Core মডেলের মাধ্যমে Kafka-এর সঙ্গে ইন্টারঅ্যাকশন করতে দেয়, Kafka-নির্দিষ্ট ক্লায়েন্ট কোড বিূর্ত করে।

Apache Kafka হলো একটি ওপেন-সোর্স ডিস্ট্রিবিউটেড ইভেন্ট স্ট্রিমিং প্ল্যাটফর্ম, যা উচ্চ-ক্ষমতাসম্পন্ন ডেটা পাইপলাইন, স্ট্রিমিং অ্যানালিটিক্স এবং ডেটা ইন্টিগ্রেশনের জন্য ডিজাইন করা হয়েছে।

প্যাথওয়ে স্ট্রিম প্রসেসিং, রিয়েল-টাইম অ্যানালিটিক্স এবং LLM ও RAG অ্যাপ্লিকেশনসহ AI পাইপলাইনের জন্য একটি পাইথন ETL ফ্রেমওয়ার্ক। এটি ইনক্রিমেন্টাল কম্পিউটেশনের জন্য রাস্ট ইঞ্জিনের উপর পাইথন কোড চালায়, একই কোডের মাধ্যমে ব্যাচ এবং স্ট্রিমিং ডেটা উভই সাপোর্ট করে, এবং ডকার ও কুবারনেটিসের মাধ্যমে ডিপ্লয় হয়।