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