الملفات والمجلدات المهمة

دليل التثبيت الرئيسي لـ Kafka: /opt/kafka
ملف تكوين وسيط Kafka: /opt/kafka/config/server.properties
دليل سجلات Kafka (سجلات الوسيط، الأحداث المحتفظ بها): /opt/kafka/logs
ثنائيات كافكا وأدوات CLI (kafka-topics.sh, kafka-console-producer.sh، إلخ): /opt/kafka/bin
وحدة خدمة Systemd لإدارة Kafka: /etc/systemd/system/kafka.service

خدمة كافكا

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 التوقف عن القراءة.

يمكن استهلاك الأحداث عدة مرات من قبل عدة عملاء.

السجلات واستكشاف الأخطاء وإصلاحها

أباتشي كافكا

تفاصيل الطلب