500+ Kafka Interview Questions with Answers 2026

أهلا بك عزيزي المتابع لموقع (journey for learn) نقدم دورات بكوبونات متاحة لاول 1000 تسجيل مجاني فقط وكوبونات اخري لفترة محدودة فاذا كنت تريد ان تحصل علي كل الكورسات علي موقعنا وان تكون اول المسجلين في الكورسات المجانية قم بتسجيل الدخول أوقم بالدخول علي وسائل التواصل الاجتماعي وخصوصا التليجرام نوضح الوصف المختصر والطويل للدورات لكي تعرف الدروس التي سوف تتعلمها بسهولة ويسر :

تغطية تفصيلية لنطاق الاختبار تم تصميم مستودع الاختبار التدريبي هذا ليعكس التوزيع الفني الدقيق والتعقيد الذي تمت مواجهته في حلقات مقابلة Apache Kafka وهندسة البيانات والأنظمة الموزعة على مستوى المؤسسة.

• أساسيات كافكا (13%): بنية كافكا الأساسية، ومكونات النظام البيئي، وطوبولوجيا وسيط الرسائل، وحالات استخدام تدفق البيانات في الوقت الفعلي، وفوائد الفصل.
• واجهات برمجة تطبيقات كافكا للمنتج والمستهلك (20%): متزامنة مقابل عمليات الإرسال غير المتزامنة، وأنواع الضغط، ودلالات التسليم (مرة واحدة على الأقل، مرة واحدة على الأكثر، مرة واحدة تمامًا)، ومجموعات المستهلكين، وبروتوكولات إعادة التوازن، ومعالجة الأخطاء المتقدمة.
• تقسيم كافكا والنسخ المتماثل (18%): استراتيجيات التقسيم المخصصة، وتجزئة السجل، وميكانيكا عامل النسخ المتماثل، وقوائم النسخ المتماثلة المتزامنة (ISR)، وسيناريوهات اختيار القائد في ظل ظروف الفشل.
• مجموعة كافكا الإدارة (12%): عمليات الوسيط، والخطوط الأساسية لتكوين المجموعة، ووضع Kraft مقابل تنسيق ZooKeeper، والترقيات المتدرجة، وقياس العقدة الديناميكية، والنسخ المتطابق متعدد المجموعات.
• ضبط أداء Kafka وتحسينه (10%): موازنة الإنتاجية مقابل زمن الاستجابة، وضبط تجمع المخزن المؤقت، وتحسينات حجم الدفعة، وتكوينات المخزن المؤقت للمقبس، وحل عنق الزجاجة للإدخال/الإخراج للقرص/الشبكة.
• أمن ومصادقة كافكا. (8%): تشفير أمان طبقة النقل (TLS/SSL)، وآليات SASL (SCRAM، وGSSAPI، وOAUTHBEARER)، وقواعد ترخيص ACL، والاتصالات الآمنة بين الوسطاء.
• تكامل كافكا والمواضيع المتقدمة (12%): إطار عمل Kafka Connect (بنية المصدر والحوض)، وطوبولوجيا Kafka Streams API، والمعالجة ذات الحالة مقابل المعالجة عديمة الحالة، وتنفيذ سجل المخطط، ومناطق متعددة واسعة النطاق. عمليات النشر.
• استكشاف أخطاء كافكا وإصلاحها والصيانة (7%): تصحيح أخطاء قوائم الانتظار ذات الأحرف الميتة، وتحليل سجلات جمع البيانات المهملة والوسيط، وإصلاح مجموعات المستهلكين العالقة، وسير عمل صيانة صحة المجموعة.

حول الدورة التدريبية يتطلب إجراء مقابلة لمهندس كافكا، أو مهندس بيانات أول، أو مهندس الأنظمة الموزعة فهمًا ميكانيكيًا عميقًا لكيفية تدفق البيانات عبر المجموعة. لا يسأل القائمون على المقابلات عن الموضوع فحسب، بل يختبرونك في حالات حافة واقعية: إعادة توازن مجموعة المستهلكين أثناء حركة المرور العالية، وسيناريوهات فقدان البيانات عند وفاة الوسيط، وضبط معلمات الدُفعات لتحسين حمل الشبكة. لقد قمت بتطوير بنك الأسئلة الشامل هذا لوضع معرفتك في مواجهة ضغوط العالم الحقيقي. تضم هذه الدورة التدريبية 550 سؤالًا تدريبيًا أصليًا ومفصلاً للغاية، وتبتعد عن التعريفات الضحلة. وبدلاً من ذلك، أركز على المقايضات المعمارية ومصائد التكوين وسيناريوهات تصحيح الأخطاء التي يواجهها كبار المهندسين في أنظمة الإنتاج. يتضمن كل سؤال تحليلاً شاملاً سطرًا تلو الآخر ليس فقط يوضح سبب كون الاختيار الصحيح صحيحًا، ولكن من الناحية الهيكلية سبب فشل التكوينات البديلة والخيارات المعمارية. سواء كنت تستعد لدور هندسة برمجيات عالي الأجر، أو تتطلع إلى توسيع نطاق معالجة التدفق الحالي، أو التحقق من مهارات تصميم النظام الخاص بك قبل مقابلة اللجنة القادمة، فإن هذا المستودع يمنحك الإعداد الدقيق والصارم اللازم لاجتياز جولاتك الفنية في المحاولة الأولى. معاينة أسئلة التدريب النموذجية لتقييم العمق الفني والأسلوب التعليمي للتفسيرات داخل بنك الأسئلة هذا، يرجى مراجعة نماذج الأسئلة الثلاثة هذه. السؤال 1: تفريغ عمليات إعادة توازن مجموعة المستهلكين ومهلة الجلسة التكوينات: تواجه مجموعة المستهلكين عالية الإنتاجية عمليات إعادة توازن متكررة ومتتالية على الرغم من أن تطبيقات المستهلك سليمة من الناحية الهيكلية وقيد التشغيل. عند التحقق من المقاييس، لاحظت أن معالجة مجموعة فردية من السجلات تستغرق أحيانًا وقتًا أطول من المتوقع بسبب عمليات قاعدة البيانات النهائية الثقيلة. ما هو تعديل التكوين الذي يعمل على إصلاح هذه المشكلة مباشرة دون إخفاء أعطال التطبيق الحقيقية؟

• أ) زيادة الجلسة بشكل كبير. نفذ الوقت. قيمة مللي ثانية مع الحفاظ على الحد الأقصى. استطلاع. فاصلة. مللي ثانية دون تغيير تمامًا.
• ب) تقليل الحد الأقصى. استطلاع. إعداد السجلات وزيادة الحد الأقصى. استطلاع. فاصلة. عتبة تكوين مللي ثانية.
• ج) زيادة نبضات القلب. فاصلة. تتجاوز المعلمة ms قيمة العتبة للجلسة المحددة. نفذ الوقت. مللي ثانية.
• د) قم بتبديل معلمة استراتيجية تعيين المستهلك من Cooperative Sticky إلى نموذج Range Assignor التقليدي.
• E) قم بتقليل العدد الفعلي للأقسام المخصصة للموضوع لإجبار عدد أقل من المستهلكين على الانضمام إلى المجمع.
• F) قم بتعيين التمكين. آلي. الالتزام بالخطأ وتنفيذ الالتزامات المتزامنة اليدوية على الفور داخل حلقة المعالجة.

الإجابة الصحيحة والشرح:

• الإجابة الصحيحة: ب
• لماذا هي صحيحة: في مستهلكي كافكا المعاصرين، تتم معالجة نبضات القلب (التي تبقي المستهلك على قيد الحياة في المجموعة) في سلسلة خلفية منفصلة تحكمها الجلسة. نفذ الوقت. آنسة. ومع ذلك، إذا استغرق مؤشر ترابط المعالجة الرئيسي وقتًا طويلاً لمعالجة مجموعة من السجلات التي تم إرجاعها بواسطة استدعاء .poll() واحد، فسوف يفتقد استدعاء الاستقصاء التالي. يستخدم كافكا الحد الأقصى. استطلاع. فاصلة. مللي ككاشف للحيوية لحلقة المعالجة. إذا تم تجاوز هذه الفترة، يقوم المنسق بطرد المستهلك، مما يؤدي إلى إعادة التوازن. يؤدي تقليل الحد الأقصى.poll.records إلى ضمان معالجة دفعات أصغر بشكل أسرع، مع زيادة الحد الأقصى. استطلاع. فاصلة. يمنح ms مؤشر الترابط مزيدًا من الوقت لإكمال العمليات الثقيلة.
• لماذا الخيارات البديلة غير صحيحة:
  • الخيار أ غير صحيح: زيادة الجلسة. نفذ الوقت. يساعد ms فقط في حالة فشل مؤشر ترابط نبضات القلب في الخلفية، وهذه ليست المشكلة عند توقف حلقة المعالجة نفسها.
  • الخيار C غير صحيح: نبضات القلب. فاصلة. يجب أن تكون مللي ثانية دائمًا أقل من الجلسة. نفذ الوقت. مللي ثانية (عادة الثلث)؛ يعد تعيينه على مستوى أعلى تكوينًا غير صالح.
  • الخيار د غير صحيح: يقوم المعين التعاوني الثابت فعليًا بتقليل اضطرابات إعادة التوازن مقارنةً بمخصص النطاق؛ العودة إلى النطاق ستؤدي إلى تفاقم صدمة الأداء.
  • الخيار E غير صحيح: تغيير أعداد الأقسام لا يعالج عدم التطابق بين وقت المعالجة وفترات الاستقصاء داخل المستهلكين النشطين.
  • الخيار F غير صحيح: تغيير أنماط الالتزام يغير ضمانات التسليم، ولكنه لا يغير مهلات منسق المجموعة الأساسية التي تحكم فترات الاستقصاء.

السؤال 2: تقييم متانة البيانات والمنتج يقبل التكويناتبيانات يقوم المهندس بإعداد موضوع كافكا على مستوى المؤسسة مع عامل النسخ المتماثل 3 ويقوم بتعيين التكوين على مستوى الموضوع min.insync.replicas إلى 2. يتم تكوين المنتج باستخدام acks=all. إذا واجه اثنان من الوسطاء الثلاثة الذين يستضيفون النسخ المتماثلة النشطة لقسم معين فجأة فشلًا ماديًا في الأجهزة وانقطعوا عن الاتصال بالإنترنت، فما هو السلوك الذي سيواجهه المنتج في محاولات الكتابة اللاحقة؟

• أ) سيكتب المنتج بنجاح إلى الوسيط الرائد المتبقي، وسيتم نسخ البيانات لاحقًا بشكل غير متزامن.
• ب) سيختار منسق المجموعة على الفور تابعًا على عقدة سليمة ويقوم بترقيته إلى القائد دون إسقاط أي اتصال.
• ج) سيحصل المنتج على خطأ NotEnoughReplicasException أو NotEnoughReplicasAfterAppendException، وستفشل عملية الكتابة.
• د) سيتم تنفيذ الكتابة بنجاح، لكن الوسيط سيفرض تخفيضًا فوريًا لعامل النسخ المتماثل الشامل للموضوع إلى 1.
• هـ) سيدخل الوسيط في وضع القراءة فقط، حيث يقوم بتخزين حمولات المنتج الواردة بالكامل في كتل ذاكرة التخزين المؤقت لذاكرة نظام التشغيل.
• و) سيتحول المنتج تلقائيًا إلى احتياطي غير متزامن قائمة الانتظار، وتجاوز الوسيط تمامًا حتى يستيقظ.

الإجابة الصحيحة والشرح:

• الإجابة الصحيحة: C
• لماذا هي صحيحة: عندما يستخدم المنتج acks=all (أو acks=-1)، يطلب كافكا من الوسيط الرئيسي تلقي الإقرارات من إجمالي عدد النسخ المتماثلة المتزامنة المحددة بواسطة إعداد min.insync.replicas للموضوع قبل تأكيد الكتابة الناجحة. نظرًا لأن عامل النسخ هو 3 ومات وسيطان، تبقى نسخة طبق الأصل واحدة فقط (القائد) على قيد الحياة. نظرًا لأن 1 أقل من الحد الأدنى المطلوب وهو 2، سيرفض الوسيط الرائد الكتابة ويعيد NotEnoughReplicasException إلى العميل المنتج لحماية ضمانات متانة البيانات.
• لماذا تكون الخيارات البديلة غير صحيحة:
  • الخيار A غير صحيح: لا يمكن للوسيط قبول الكتابة بموجب سياسة acks=all إذا تم كسر الحد الأدنى لمتطلبات عدد النسخ المتماثلة المتزامنة.
  • الخيار B غير صحيح: لا توجد نسخ متماثلة أخرى باقية للترويج؛ كلا التابعين غير متصلين بالإنترنت، مما يترك فقط القائد المعزول الحالي.
  • الخيار د غير صحيح: لا يغير كافكا أبدًا تخطيطات بيانات التعريف ديناميكيًا أو يخفض تكوينات عامل النسخ تلقائيًا بسبب فشل البنية التحتية.
  • الخيار E غير صحيح: لا يقوم الوسيط بتخزين السجلات غير المعترف بها في مخزن مؤقت لذاكرة النظام عندما تفشل حدود المتانة.
  • الخيار F غير صحيح: لا يعرض المنتجون من جانب العميل قوائم انتظار داخلية تلقائية مستقلة لتخزين السجلات خارج حدود المجموعة عندما يتم رفض عمليات الكتابة بشكل صريح.

السؤال 3: إدارة مخزن الحالة وضبط الذاكرة في بنية Kafka Streamsيواجه تطبيق Kafka Streams ذو الحالة التي تستخدم عمليات ربط KTable تحطيمًا شديدًا للإدخال/الإخراج للقرص والأداء البطيء أثناء التدفقات كبيرة الحجم في الوقت الفعلي. يشير التوصيف إلى أن مثيلات RocksDB المضمنة تقوم بشكل متكرر بنقل كتل البيانات الصغيرة إلى ملفات القرص الفعلي. ما هو أسلوب التحسين الذي يعمل على قياس إنتاجية التطبيق بشكل نظيف؟

• أ) زيادة معلمةstatestore.cache.max.bytes ضمن خصائص دفق تكوين التطبيق.
• ب) تغيير بنية طوبولوجيا كافكا لاستبدال KTable ذي الحالة بالكامل بإعداد تعيين KStream عديم الحالة.
• ج) فرض تغيير مجموعة عمومية لتعطيل موضوع سجل التغيير المدعوم بمحرك حالة الدفق الداخلي.
• د) تقليل حجم كومة الذاكرة المؤقتة للتطبيق JVM للسماح لمدير الذاكرة الافتراضية لنظام التشغيل بإخراج الكتل النشطة الفعلية.
• هـ) لف منطق المعالجة داخل قسم مخصص لتعيين مفاتيح عشوائية لكل حمولة سجل واردة.
• F) تقليل حد حجم مقطع السجل لموضوعات تدفق المصدر الأساسي لفرض التنظيف الفوري للخلفية.

الإجابة الصحيحة والشرح:

• الإجابة الصحيحة: أ
• لماذا هذا صحيح: تعمل Kafka Streams على تعزيز طبقة ذاكرة التخزين المؤقت الداخلية المدعومة بالذاكرة الموجودة مباشرة فوق متجر RocksDB المحلي الفعلي. تسمح زيادة Statestore.cache.max.bytes لـ Kafka Streams بتخزين المزيد من اختلافات الحالة والتجميعات والتحديثات مباشرة في ذاكرة النظام. يؤدي هذا إلى تقليل تكرار عمليات الكتابة باهظة الثمن بشكل كبير وصولاً إلى مثيل RocksDB المحلي، مما يقلل من تدفق الإدخال/الإخراج على القرص الفعلي وتحقيق استقرار إنتاجية التطبيق.
• لماذا تكون الخيارات البديلة غير صحيحة:
  • الخيار B غير صحيح: بينما يؤدي استبدال العمليات ذات الحالة بمعالجة عديمة الحالة إلى إزالة الاعتماد على القرص، فإنه يغير منطق التطبيق الأساسي؛ لا يمكنك إجراء عمليات الانضمام دون إدارة الحالة.
  • الخيار C غير صحيح: يؤدي تعطيل موضوع سجل التغيير إلى تدمير التسامح مع الخطأ، مما يعني أنه في حالة تعطل مثيل الدفق، لا يمكن لمخزن الحالة إعادة بناء نفسه.
  • الخيار D غير صحيح: يؤدي تقليص مساحة الكومة JVM إلى تفاقم سرعات التنفيذ ويخاطر بحدوث أخطاء OutOfMemory إذا كان التطبيق يتطلب هياكل تتبع واسعة النطاق.
  • الخيار E غير صحيح: يؤدي توزيع مفاتيح السجل بشكل عشوائي إلى كسر قواعد التقسيم المشترك المستندة إلى المفتاح المطلوبة للتدفق. الانضمامات، مما يتسبب في عمليات بحث عن بيانات تالفة.
  • الخيار F غير صحيح: يؤثر ضبط حجم مقطع السجل لموضوعات المصدر الأساسية على الاحتفاظ بمساحة القرص، لكنه لا يحل مشكلة التخزين المؤقت للذاكرة داخل محرك وقت تشغيل RocksDB المحلي.

ما يمكن توقعه

• مرحبًا بك في اختبارات أسئلة المقابلة لمساعدتك في الاستعداد لتقييم أسئلة مقابلة كافكا
• يمكنك إعادة إجراء الاختبارات عدة مرات تريد
• هذا بنك أسئلة أصلي ضخم
• يمكنك الحصول على الدعم من المدربين إذا كانت لديك أسئلة
• يحتوي كل سؤال على شرح مفصل
• متوافق مع الهاتف المحمول مع تطبيق Udemy

نأمل أن تكون مقتنعًا الآن! وهناك الكثير من الأسئلة داخل الدورة.

ما هي المتطلبات الأساسية لدخول الدورة والتسجيل فيها على موقعنا؟ رحلة التعلم:

(احصل على الدورة للدخول إلى الموقع والتسجيل)

يجب أن يكون لديك بريد إلكتروني (حساب بريد) تتذكره لنفسك وأيضًا يجب أن تتذكر كلمة مرور البريد الإلكتروني الذي ستسجل به ، وإذا لم يكن لديك حساب بريد إلكتروني ، فمن الأفضل إنشاء حساب (Gmail)