1.单节点搭建

1.1 下载安装包

#解压
tar -xzf kafka_2.12-3.3.1.tgz 
#修改名字，也可以修改也可以不改
mv kafka_2.12-3.3.1 kafka-2.12

1.2 配置环境变量

vi /etc/profile
# 加入以下配置
export KAFKA_HOME=/opt/software/kafka_2.12-3.3.1
export PATH=$PATH:$KAFKA_HOME/bin

#重新加载配置文件
source /etc/profile

1.3 配置配置文件

单机版的可以不进行修改

vi server.properties

broker.id=0     #注意：这里要唯一的Integer类型
log.dirs=/kafka-logs    #真实数据存储的位置
zookeeper.connect=node02:2181 #zookeeper

1.4 启动

启动zookeeper

# Start the ZooKeeper service
$ bin/zookeeper-server-start.sh config/zookeeper.properties

启动kafka

$ bin/kafka-server-start.sh /opt/software/kafka_2.12-3.3.1/config/server.properties

1.5 创建启动脚本startKafka.sh

在安装目录下创建启动脚本

nohup  /opt/software/kafka_2.12-3.3.1/bin/kafka-server-start.sh /opt/software/kafka_2.12-3.3.1/config/server.properties > /opt/software/kafka_2.12-3.3.1 /kafkalog.txt 2>&1 &

启动

[root@node02 bin]# ./startKafka.sh
[root@node02 bin]# jps
12673 Kafka
9234 QuorumPeerMain
13036 Jps

2.简单的使用

2.1 创建topic

[root@node02 bin]# ./kafka-topics.sh --create --topic mytopic --bootstrap-server localhost:9092
Created topic mytopic.

2.2 查看topic

[root@node02 bin]# ./kafka-topics.sh --list --bootstrap-server localhost:9092
mytopic

2.3 producer生产数据

[root@node02 bin]# ./kafka-console-producer.sh --topic mytopic --bootstrap-server localhost:9092
>hello,kafka
>hello,world
>

2.4 consumer消费者拉取数据

[root@node02 bin]# ./kafka-console-consumer.sh --topic mytopic --from-beginning --bootstrap-server localhost:9092
hello,kafka
hello,world