Apache Kafka - ขั้นตอนการติดตั้ง

ต่อไปนี้เป็นขั้นตอนในการติดตั้ง Java บนเครื่องของคุณ

ขั้นตอนที่ 1 - ตรวจสอบการติดตั้ง Java

หวังว่าคุณได้ติดตั้ง 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

ในการทำให้ java พร้อมใช้งานสำหรับผู้ใช้ทั้งหมดให้ย้ายเนื้อหา java ที่แยกแล้วไปยังusr / local / java / folder

$ 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

ใช้คำสั่งต่อไปนี้เพื่อเปลี่ยน Java Alternatives

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

Step 1.6 - ตอนนี้ตรวจสอบ java โดยใช้คำสั่งการตรวจสอบ (java -version) ที่อธิบายไว้ในขั้นตอนที่ 1

ขั้นตอนที่ 2 - การติดตั้ง ZooKeeper Framework

ขั้นตอนที่ 2.1 - ดาวน์โหลด ZooKeeper

ในการติดตั้ง ZooKeeper framework บนเครื่องของคุณให้ไปที่ลิงค์ต่อไปนี้และดาวน์โหลด ZooKeeper เวอร์ชันล่าสุด

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

ณ ตอนนี้ ZooKeeper เวอร์ชันล่าสุดคือ 3.4.6 (ZooKeeper-3.4.6.tar.gz)

ขั้นตอนที่ 2.2 - แตกไฟล์ tar

แตกไฟล์ tar โดยใช้คำสั่งต่อไปนี้

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

ขั้นตอนที่ 2.3 - สร้างไฟล์กำหนดค่า

เปิดไฟล์คอนฟิกูเรชันชื่อconf / zoo.cfgโดยใช้คำสั่ง vi“ 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 - เริ่ม CLI

$ bin/zkCli.sh

หลังจากพิมพ์คำสั่งด้านบนคุณจะเชื่อมต่อกับเซิร์ฟเวอร์ Zookeeper และจะได้รับคำตอบด้านล่าง

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

ขั้นตอนที่ 3 - การติดตั้ง Apache Kafka

ให้เราทำตามขั้นตอนต่อไปนี้เพื่อติดตั้ง Kafka บนเครื่องของคุณ

ขั้นตอนที่ 3.1 - ดาวน์โหลด Kafka

ในการติดตั้ง Kafka บนเครื่องของคุณคลิกที่ลิงค์ด้านล่าง -

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

ตอนนี้เป็นเวอร์ชันล่าสุดคือ - kafka_2.11_0.9.0.0.tgz จะถูกดาวน์โหลดลงในเครื่องของคุณ

ขั้นตอนที่ 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

ตอนนี้เราได้พูดคุยเกี่ยวกับการติดตั้ง Kafka แล้วเราสามารถเรียนรู้วิธีดำเนินการพื้นฐานบน Kafka ได้ในบทถัดไป