استخدام كافكا لعمل منتج و مستخدم للتواصل مع سيرفر على الجهاز

مستودع Kafka يحتوي على سكربتات Python تهدف إلى تسهيل استهلاك ومعالجة الرسائل باستخدام كافكا. فيما يلي شرح لمحتويات الملفات:

Consumer_BW.py: ينفذ مستهلك كافكا يقوم بمعالجة الرسائل الواردة من مواضيع كافكا، ومن المحتمل أن تتعلق البيانات بالصور بناءً على سياق المشروع.

consumer_server_upload.py: يتعامل مع التكامل بين كافكا والخادم، ويرفع البيانات التي تم معالجتها.

server.py: يدير العمليات من جانب الخادم، ويتفاعل مع مستهلكي كافكا للتعامل مع تدفق البيانات في الوقت الحقيقي.