Apache Kafka - Langkah Pemasangan

Berikut ialah langkah-langkah untuk memasang Java pada mesin anda.

Langkah 1 - Mengesahkan Pemasangan Java

Semoga anda sudah memasang java di mesin anda sekarang, jadi anda hanya mengesahkannya menggunakan perintah berikut.

$ java -version

Jika java berjaya dipasang pada mesin anda, anda dapat melihat versi Java yang dipasang.

Langkah 1.1 - Muat turun JDK

Sekiranya Java tidak dimuat turun, sila muat turun versi terkini JDK dengan melawat pautan berikut dan muat turun versi terkini.

http://www.oracle.com/technetwork/java/javase/downloads/index.html

Sekarang versi terkini ialah JDK 8u 60 dan failnya adalah "jdk-8u60-linux-x64.tar.gz". Sila muat turun fail pada mesin anda.

Langkah 1.2 - Fail Extract

Umumnya, fail yang dimuat turun disimpan dalam folder muat turun, mengesahkannya dan mengeluarkan tetapan tar menggunakan perintah berikut.

$ cd /go/to/download/path
$ tar -zxf jdk-8u60-linux-x64.gz

Langkah 1.3 - Pindahkan ke Direktori Opt

Untuk membuat java tersedia kepada semua pengguna, gerakkan kandungan java yang diekstrak ke usr / local / java / folder.

$ su
password: (type password of root user)
$ mkdir /opt/jdk
$ mv jdk-1.8.0_60 /opt/jdk/

Langkah 1.4 - Tetapkan laluan

Untuk menetapkan pembolehubah laluan dan JAVA_HOME, tambah arahan berikut untuk fail ~ / .bashrc.

export JAVA_HOME =/usr/jdk/jdk-1.8.0_60
export PATH=$PATH:$JAVA_HOME/bin

Sekarang gunakan semua perubahan ke dalam sistem berjalan semasa.

$ source ~/.bashrc

Langkah 1.5 - Alternatif Java

Gunakan arahan berikut untuk menukar Alternatif Java.

update-alternatives --install /usr/bin/java java /opt/jdk/jdk1.8.0_60/bin/java 100

Langkah 1.6 - Sekarang sahkan java menggunakan arahan pengesahan (java -version) yang dijelaskan dalam Langkah 1.

Langkah 2 - Pemasangan Rangka ZooKeeper

Langkah 2.1 - Muat turun ZooKeeper

Untuk memasang rangka kerja ZooKeeper pada mesin anda, lawati pautan berikut dan muat turun versi terkini ZooKeeper.

http://zookeeper.apache.org/releases.html

Sehingga kini, versi terbaru ZooKeeper ialah 3.4.6 (ZooKeeper-3.4.6.tar.gz).

Langkah 2.2 - Ekstrak fail tar

Ekstrak fail tar menggunakan arahan berikut

$ cd opt/
$ tar -zxf zookeeper-3.4.6.tar.gz
$ cd zookeeper-3.4.6
$ mkdir data

Langkah 2.3 - Buat Fail Konfigurasi

Buka Fail Konfigurasi bernama conf / zoo.cfg menggunakan perintah vi "conf / zoo.cfg" dan semua parameter berikut untuk ditetapkan sebagai titik permulaan.

$ vi conf/zoo.cfg
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
syncLimit=2

Apabila fail konfigurasi telah berjaya disimpan dan kembali ke terminal lagi, anda boleh memulakan pelayan zookeeper.

Langkah 2.4 - Mula Server ZooKeeper

$ bin/zkServer.sh start

Selepas melaksanakan arahan ini, anda akan mendapat respons seperti ditunjukkan di bawah -

$ JMX enabled by default
$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg
$ Starting zookeeper ... STARTED

Langkah 2.5 - Mula CLI

$ bin/zkCli.sh

Selepas menaip arahan di atas, anda akan disambungkan ke pelayan zookeeper dan akan mendapat sambutan di bawah.

Connecting to localhost:2181
................
................
................
Welcome to ZooKeeper!
................
................
WATCHER::
WatchedEvent state:SyncConnected type: None path: null
[zk: localhost:2181(CONNECTED) 0]

Langkah 2.6 - Hentikan Pelayan Zookeeper

Selepas menyambung pelayan dan melakukan semua operasi, anda boleh menghentikan pelayan zookeeper dengan arahan berikut -

$ bin/zkServer.sh stop

Sekarang anda telah berjaya memasang Java dan ZooKeeper pada mesin anda. Marilah kita melihat langkah-langkah untuk memasang Apache Kafka.

Langkah 3 - Pemasangan Apache Kafka

Marilah kita meneruskan langkah-langkah berikut untuk memasang Kafka pada mesin anda.

Langkah 3.1 - Muat turun Kafka

Untuk memasang Kafka pada mesin anda, klik pada pautan di bawah -

https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz

Sekarang versi terkini iaitu - kafka_2.11_0.9.0.0.tgz akan dimuat turun ke mesin anda.

Langkah 3.2 - Ekstrak fail tar

Ekstrak fail tar menggunakan arahan berikut -

$ cd opt/
$ tar -zxf kafka_2.11.0.9.0.0 tar.gz
$ cd kafka_2.11.0.9.0.0

Kini anda telah memuat turun versi terbaru Kafka pada mesin anda.

Langkah 3.3 - Mula Server

Anda boleh mulakan pelayan dengan memberikan arahan berikut -

$ bin/kafka-server-start.sh config/server.properties

Selepas pelayan bermula, anda akan melihat sambutan di bawah di skrin anda -

$ 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
…………………………………………….
…………………………………………….

Langkah 4 - Hentikan Server

Selepas melakukan semua operasi, anda boleh menghentikan pelayan menggunakan arahan berikut -

$ bin/kafka-server-stop.sh config/server.properties

Sekarang kita telah membincangkan pemasangan Kafka, kita boleh belajar bagaimana untuk melaksanakan operasi asas pada Kafka dalam bab seterusnya.