مفاهيم معالجة التدفقات
في هذا الدرس 4 موضوعات
هذا الدرس مخطط له. يعرض المخطط أدناه الموضوعات التي سيغطيها، ولم يُنشر الدرس الكامل بعد.
نص الدروس والتمارين باللغة الإنجليزية، بينما تبقى واجهة الموقع وعناوين الدروس بالعربية.
في هذا الدرس
describe enrichment and aggregation on streams.
الموضوعات المخطط لها
- Stream processors apply stateful operations: joins, windows, aggregations.
- Event time versus processing time; late events need a policy.
- State stores are rebuilt from changelog topics, so recovery has a cost.
- Choose Kafka Streams for library-style, Flink for larger stateful jobs; verify before recording.
تفاصيل المخطط المبدئي
عرض عملي
a topology: stock changes joined with a product table, aggregated per warehouse in 1-minute windows, written to a topic.
اختبر فهمك
What is a late event?
أظهر الإجابة
One arriving after its time window was processed.
التطبيق
طبّق هذا الدرس بمختبر الوحدة وتمارينها واختبارها.
تعليم الدرس كمكتمل اختياري ويمكنك التراجع عنه في أي وقت. يبقى تقدمك محفوظًا في هذا المتصفح.