Apache Kafka - Các bước cài đặt

Sau đây là các bước để cài đặt Java trên máy của bạn.

Bước 1 - Xác minh cài đặt Java

Hy vọng rằng bạn đã cài đặt java trên máy tính của mình ngay bây giờ, vì vậy bạn chỉ cần xác minh nó bằng cách sử dụng lệnh sau.

$ java -version

Nếu java được cài đặt thành công trên máy của bạn, bạn có thể thấy phiên bản Java đã cài đặt.

Bước 1.1 - Tải xuống JDK

Nếu Java chưa được tải xuống, vui lòng tải xuống phiên bản mới nhất của JDK bằng cách truy cập liên kết sau và tải xuống phiên bản mới nhất.

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

Hiện phiên bản mới nhất là JDK 8u 60 và tệp là “jdk-8u60-linux-x64.tar.gz”. Vui lòng tải xuống tệp trên máy của bạn.

Bước 1.2 - Giải nén tệp

Nói chung, các tệp đang được tải xuống được lưu trữ trong thư mục tải xuống, xác minh nó và trích xuất thiết lập tar bằng các lệnh sau.

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

Bước 1.3 - Di chuyển đến Opt Directory

Để cung cấp java cho tất cả người dùng, hãy di chuyển nội dung java đã giải nén vào thư mục usr / local / java /.

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

Bước 1.4 - Đặt đường dẫn

Để đặt đường dẫn và các biến JAVA_HOME, hãy thêm các lệnh sau vào tệp ~ / .bashrc.

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

Bây giờ áp dụng tất cả các thay đổi vào hệ thống đang chạy hiện tại.

$ source ~/.bashrc

Bước 1.5 - Các lựa chọn thay thế Java

Sử dụng lệnh sau để thay đổi Java Alternatives.

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

Step 1.6 - Bây giờ xác minh java bằng lệnh xác minh (java -version) được giải thích trong Bước 1.

Bước 2 - Cài đặt ZooKeeper Framework

Bước 2.1 - Tải xuống ZooKeeper

Để cài đặt ZooKeeper framework trên máy của bạn, hãy truy cập liên kết sau và tải xuống phiên bản ZooKeeper mới nhất.

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

Hiện tại, phiên bản mới nhất của ZooKeeper là 3.4.6 (ZooKeeper-3.4.6.tar.gz).

Bước 2.2 - Giải nén tệp tar

Giải nén tệp tar bằng lệnh sau

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

Bước 2.3 - Tạo tệp cấu hình

Mở tệp cấu hình có tên conf / zoo.cfg bằng lệnh vi “conf / zoo.cfg” và tất cả các tham số sau để đặt làm điểm bắt đầu.

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

Khi tệp cấu hình đã được lưu thành công và trở lại thiết bị đầu cuối, bạn có thể khởi động máy chủ của người giữ vườn thú.

Bước 2.4 - Khởi động Máy chủ ZooKeeper

$ bin/zkServer.sh start

Sau khi thực hiện lệnh này, bạn sẽ nhận được phản hồi như hình dưới đây:

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

Bước 2.5 - Khởi động CLI

$ bin/zkCli.sh

Sau khi gõ lệnh trên, bạn sẽ được kết nối với máy chủ của Zookeeper và sẽ nhận được phản hồi bên dưới.

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

Bước 2.6 - Dừng máy chủ Zookeeper

Sau khi kết nối máy chủ và thực hiện tất cả các thao tác, bạn có thể dừng máy chủ sở thú bằng lệnh sau:

$ bin/zkServer.sh stop

Bây giờ bạn đã cài đặt thành công Java và ZooKeeper trên máy của mình. Hãy để chúng tôi xem các bước để cài đặt Apache Kafka.

Bước 3 - Cài đặt Apache Kafka

Hãy để chúng tôi tiếp tục các bước sau để cài đặt Kafka trên máy của bạn.

Bước 3.1 - Tải xuống Kafka

Để cài đặt Kafka trên máy của bạn, hãy nhấp vào liên kết dưới đây -

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

Bây giờ là phiên bản mới nhất, tức là - kafka_2.11_0.9.0.0.tgz sẽ được tải xuống máy của bạn.

Bước 3.2 - Giải nén tệp tar

Giải nén tệp tar bằng lệnh sau:

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

Bây giờ bạn đã tải xuống phiên bản mới nhất của Kafka trên máy của mình.

Bước 3.3 - Khởi động máy chủ

Bạn có thể khởi động máy chủ bằng cách đưa ra lệnh sau:

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

Sau khi máy chủ khởi động, bạn sẽ thấy phản hồi dưới đây trên màn hình của mình -

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

Bước 4 - Dừng máy chủ

Sau khi thực hiện tất cả các thao tác, bạn có thể dừng máy chủ bằng lệnh sau:

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

Bây giờ chúng ta đã thảo luận về cài đặt Kafka, chúng ta có thể tìm hiểu cách thực hiện các thao tác cơ bản trên Kafka trong chương tiếp theo.