文章目录
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
