الملفات والمجلدات الرئيسية
- دليل تثبيت Kafka الرئيسي:
/opt/kafka - ملف إعدادات Kafka broker:
/opt/kafka/config/server.properties - دليل سجلات Kafka (سجلات broker والأحداث المحفوظة):
/opt/kafka/logs - ملفات Kafka التنفيذية وأدوات CLI (
kafka-topics.sh,kafka-console-producer.shوغيرها):/opt/kafka/bin - وحدة خدمة Systemd لإدارة Kafka:
/etc/systemd/system/kafka.service
خدمة Kafka
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
إنشاء موضوع
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
عرض تفاصيل الموضوع:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
إنتاج الأحداث (الرسائل)
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
اكتب حدثاً واحداً في كل سطر.
اضغط Ctrl+C للخروج.
استهلاك الأحداث
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
اضغط Ctrl+C لإيقاف القراءة.
يمكن لعدة عملاء استهلاك الأحداث أكثر من مرة.
السجلات واستكشاف الأخطاء
- سجلات Kafka:
/opt/kafka/logs - سجل Systemd:
sudo journalctl -u kafka -f - تأكد من أن المنافذ
9092(broker) و9093(controller) مفتوحان.
