سوف نقوم بمجموعة من الخطوات لتثبيت Apache Kafka
الخطوة 1 – التحقق من تثبيت جافا
نأمل أن تكون قد قمت بالفعل بتثبيت Java على جهازك الآن، لذا عليك فقط التحقق من ذلك باستخدام الأمر التالي.
$ java -version
إذا تم تثبيت Java بنجاح على جهازك، فيمكنك رؤية إصدار Java المثبت.
الخطوة 1.1 – تنزيل JDK
إذا لم يتم تنزيل Java، فيرجى تنزيل أحدث إصدار من JDK بزيارة الرابط التالي وتنزيل أحدث إصدار.
http://www.Oracle.com/technetwork/Java/javase/downloads/index.html
الآن الإصدار الأحدث هو JDK 8u 60 والملف هو “jdk-8u60-linux-x64.tar.gz”. يرجى تنزيل الملف على جهازك.
الخطوة 1.2 – استخراج الملفات
بشكل عام، يتم تخزين الملفات التي يتم تنزيلها في مجلد التنزيلات، قم بالتحقق منها واستخرج إعداد tar باستخدام الأوامر التالية.
$ cd /go/to/download/path
$ tar -zxf jdk-8u60-linux-x64.gz
الخطوة 1.3 – الانتقال إلى Opt Directory
لجعل جافا متاحة لجميع المستخدمين، انقل محتوى جافا المستخرج إلى المجلد usr/local/java/.
$ su
password: (type password of root user)
$ mkdir /opt/jdk
$ mv jdk-1.8.0_60 /opt/jdk/
الخطوة 1.4 – تحديد المسار
لتعيين المسار ومتغيرات JAVA_HOME، قم بإضافة الأوامر التالية إلى ملف ~/.bashrc.
export JAVA_HOME =/usr/jdk/jdk-1.8.0_60
export PATH=$PATH:$JAVA_HOME/bin
الآن قم بتطبيق كافة التغييرات على نظام التشغيل الحالي.
$ source ~/.bashrc
الخطوة 1.5 – بدائل جافا
استخدم الأمر التالي لتغيير بدائل Java.
update-alternatives --install /usr/bin/java java /opt/jdk/jdk1.8.0_60/bin/java 100
الخطوة 2 – تثبيت إطار عمل ZooKeeper
الخطوة 2.1 – تنزيل ZooKeeper
لتثبيت إطار عمل ZooKeeper على جهازك، قم بزيارة الرابط التالي وقم بتنزيل أحدث إصدار من ZooKeeper.
http://zookeeper.apache.org/releases.html
حتى الآن، أحدث إصدار من ZooKeeper هو 3.4.6 (ZooKeeper-3.4.6.tar.gz).
الخطوة 2.2 – استخراج الملف المضغوط
قم باستخراج ملف tar باستخدام الأمر التالي
$ cd opt/
$ tar -zxf zookeeper-3.4.6.tar.gz
$ cd zookeeper-3.4.6
$ mkdir data
الخطوة 2.3 – إنشاء ملف التكوين
افتح ملف التكوين المسمى conf/zoo.cfg باستخدام الأمر السادس “conf/zoo.cfg” وجميع المعلمات التالية لتعيينها كنقطة بداية.
$ vi conf/zoo.cfg
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
syncLimit=2
بمجرد حفظ ملف التكوين بنجاح والعودة إلى الوحدة الطرفية مرة أخرى، يمكنك بدء تشغيل خادم Zookeeper.
الخطوة 2.4 – بدء تشغيل خادم ZooKeeper
$ bin/zkServer.sh start
بعد تنفيذ هذا الأمر، سوف تحصل على الرد كما هو موضح أدناه
$ JMX enabled by default
$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg
$ Starting zookeeper ... STARTED
الخطوة 2.5 – ابدأ سطر الأوامر
$ bin/zkCli.sh
بعد كتابة الأمر أعلاه، سيتم توصيلك بخادم حديقة الحيوان وستحصل على الاستجابة أدناه.
Connecting to localhost:2181
................
................
................
Welcome to ZooKeeper!
................
................
WATCHER::
WatchedEvent state:SyncConnected type: None path:null
[zk: localhost:2181(CONNECTED) 0]
الخطوة 2.6 – إيقاف خادم Zookeeper
بعد توصيل الخادم وإجراء جميع العمليات، يمكنك إيقاف خادم Zookeeper باستخدام الأمر التالي
$ bin/zkServer.sh stop
لقد قمت الآن بتثبيت Java وZooKeeper بنجاح على جهازك. دعونا نرى خطوات تثبيت Apache Kafka.
Step 3 – Apache Kafka Installation
دعنا نواصل الخطوات التالية لتثبيت كافكا على جهازك.
الخطوة 3.1 – تنزيل كافكا
o install Kafka on your machine, click on the below link −https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz
Now the latest version i.e., – kafka_2.11_0.9.0.0.tgz will be downloaded onto your machine.
الخطوة 3.2 – استخراج ملف TAR
قم باستخراج ملف tar باستخدام الأمر التالي
$ cd opt/
$ tar -zxf kafka_2.11.0.9.0.0 tar.gz
$ cd kafka_2.11.0.9.0.0
لقد قمت الآن بتنزيل أحدث إصدار من Kafka على جهازك.
الخطوة 3.3 – بدء تشغيل الخادم
يمكنك بدء تشغيل الخادم بإعطاء الأمر التالي
$ bin/kafka-server-start.sh config/server.properties
بعد بدء تشغيل الخادم، سترى الاستجابة أدناه على شاشتك
$ bin/kafka-server-start.sh config/server.properties
[2016-01-02 15:37:30,410] INFO KafkaConfig values:
request.timeout.ms = 30000
log.roll.hours = 168
inter.broker.protocol.version = 0.9.0.X
log.preallocate = false
security.inter.broker.protocol = PLAINTEXT
…………………………………………….
…………………………………………….
الخطوة 4 – إيقاف الخادم
بعد تنفيذ جميع العمليات، يمكنك إيقاف الخادم باستخدام الأمر التالي
$ bin/kafka-server-stop.sh config/server.properties
الآن بعد أن ناقشنا بالفعل تثبيت كافكا، يمكننا أن نتعلم كيفية تنفيذ العمليات الأساسية على كافكا في الدرس التالي.