Kafka讀書筆記 -- 叢集安裝與配置（Ubuntu）

➜ sudo add-apt-repository ppa:webupd8team/java
➜ sudo apt-get update

➜ sudo apt-get install oracle-java8-installer

➜ sudo update-java-alternatives -s java-8-oracle

➜ mkdir ~/Downloads & cd ~/Downloads
➜ wget http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz

➜ mkdir ~/kafka && cd ~/kafka
➜ kafka tar -xvzf ~/Downloads/kafka_2.11-2.0.0.tgz--strip 1

➜ vim ~/kafka/config/server.properties

# 新增
delete.topic.enable=true

➜ sudo vim /etc/systemd/system/zookeeper.service

[Unit]
Requires=network.target remote-fs.target
After=network.target remote-fs.target

[Service]
Type=simple
User=zhongmingmao
ExecStart=/home/zhongmingmao/kafka/bin/zookeeper-server-start.sh /home/zhongmingmao/kafka/config/zookeeper.properties
ExecStop=/home/zhongmingmao/kafka/bin/zookeeper-server-stop.sh
Restart=on-abnormal

[Install]
WantedBy=multi-user.target

➜ sudo vim /etc/systemd/system/kafka.service

[Unit]
Requires=zookeeper.service
After=zookeeper.service

[Service]
Type=simple
User=zhongmingmao
ExecStart=/bin/sh -c '/home/zhongmingmao/kafka/bin/kafka-server-start.sh /home/zhongmingmao/kafka/config/server.properties > /home/zhongmingmao/kafka/kafka.log 2>&1'
ExecStop=/home/zhongmingmao/kafka/bin/kafka-server-stop.sh
Restart=on-abnormal

[Install]
WantedBy=multi-user.target

➜ sudo systemctl start kafka

➜ sudo systemctl status kafka
● kafka.service
Loaded: loaded (/etc/systemd/system/kafka.service; disabled; vendor preset: enabled)
Active: active (running) since Mon 2018-10-08 01:52:40 UTC; 6s ago

➜ sudo systemctl status zookeeper
● zookeeper.service
Loaded: loaded (/etc/systemd/system/zookeeper.service; disabled; vendor preset: enabled)
Active: active (running) since Mon 2018-10-08 01:52:40 UTC; 1min 33s ago

➜ journalctl -u kafka
➜ journalctl -u zookeeper

➜ sudo systemctl enable kafka
Created symlink /etc/systemd/system/multi-user.target.wants/kafka.service → /etc/systemd/system/kafka.service.

➜ vim ~/.zshrc

# 新增
KAFKA_HOME="/home/zhongmingmao/kafka/"
export PATH=$KAFKA_HOME/bin:$PATH

➜ source ~/.zshrc

➜ kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --partitions 1 --topic zhongmingmao
Created topic "zhongmingmao".

➜ kafka-topics.sh --zookeeper localhost:2181 --list
zhongmingmao

➜ echo "hello, zhongmingmao" | kafka-console-producer.sh --broker-list localhost:9092 --topic zhongmingmao > /dev/null

➜ kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic zhongmingmao --from-beginning
hello, zhongmingmao

➜ sudo apt install ruby ruby-dev build-essential
➜ sudo gem install kafkat

➜ vim ~/.kafkatcfg

{
"kafka_path": "~/kafka",
"log_path": "/tmp/kafka-logs",
"zk_path": "localhost:2181"
}

➜ kafkat partitions
TopicPartitionLeaderReplicasISRs
zhongmingmao00[0][0]
__consumer_offsets00[0][0]

➜ mkdir -p ~/data/zookeeper && mkdir -p ~/data/kafka

➜ vim ~/kafka/config/zookeeper.properties

dataDir=/home/zhongmingmao/data/zookeeper
clientPort=2181

maxClientCnxns=100
tickTime=2000
initLimit=10
syncLimit=5

server.1=172.16.143.133:2888:3888
server.2=172.16.143.134:2888:3888
server.3=172.16.143.135:2888:3888

➜ echo 1 > ~/data/zookeeper/myid # 不同機器，數值為1、2、3

➜ vim ~/kafka/config/server.properties

# 修改下面配置
broker.id=0 # 不同機器，數值為0、1、2
listeners=PLAINTEXT://172.16.143.133:9092 # 機器IP
zookeeper.connect=172.16.143.133:2181,172.16.143.134:2181,172.16.143.135:2181 # Zookeeper叢集
log.dirs=/home/zhongmingmao/data/kafka

➜ sudo systemctl start kafka

➜ jps
4997 Jps
4331 Kafka
4317 QuorumPeerMain

# Mac OS
➜ kafka-topics --zookeeper 172.16.143.133:2181,172.16.143.134:2181,172.16.143.135:2181 --create --replication-factor 1 --partitions 1 --topic zhongmingmao
Created topic "zhongmingmao".

➜ kafka-topics --zookeeper 172.16.143.133:2181,172.16.143.134:2181,172.16.143.135:2181 --list
zhongmingmao

# --zookeeper 可以只列一個

# Mac OS
➜ echo "hello, zhongmingmao" | kafka-console-producer --broker-list 172.16.143.133:9092,172.16.143.134:9092,172.16.143.135:9092, --topic zhongmingmao > /dev/null

# Mac OS
➜ kafka-console-consumer --bootstrap-server 172.16.143.133:9092,172.16.143.134:9092,172.16.143.135:9092 --topic zhongmingmao --from-beginning
hello, zhongmingmao

➜ vim ~/.kafkatcfg

{
"kafka_path": "/home/zhongmingmao/kafka",
"log_path": "/home/zhongmingmao/data/kafka",
"zk_path": "172.16.143.133:2181,172.16.143.134:2181,172.16.143.135:2181"
}

➜ kafkat partitions
TopicPartitionLeaderReplicasISRs
zhongmingmao02[2][2]
__consumer_offsets01[1][1]