大数据全系列 教程
1869个小节阅读:467.2k
目录
408考研
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
xxxxxxxxxx
tar -zxvf kafka_2.11-0.11.0.0.tgz -C /opt/
xxxxxxxxxx
mv kafka_2.11-0.11.0.0/ kafka
xxxxxxxxxx
mkdir logs
进入config/server.properties
xxxxxxxxxx
#broker的全局唯一编号,不能重复
broker.id=0
#删除topic功能使能
delete.topic.enable=true
auto.create.topics.enable=false
#kafka运行日志存放的路径
log.dirs=/opt/kafka/logs
#配置连接Zookeeper集群地址
zookeeper.connect=node2:2181,node3:2181,node4:2181/kafka
xxxxxxxxxx
export KAFKA_HOME=/opt/kafka
export PATH=$PATH:$KAFKA_HOME/bin
分发安装包
拷贝kafka至node3,node4
xxxxxxxxxx
scp -r /opt/kakfa node3:$PWD
scp -r /opt/kakfa node4:$PWD
注意:
分别在node3和node4上修改配置文件/opt/kafka/config/server.properties中的broker.id=1、broker.id=2。
注:broker.id不得重复
依次在node2、node3、node4节点上启动kafka
xxxxxxxxxx
bin/kafka-server-start.sh -daemon config/server.properties
xxxxxxxxxx
bin/kafka-server-stop.sh stop
xxxxxxxxxx
for i in node2 node3 node4
do
echo "========== $i =========="
ssh $i '/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties'
done
查看当前服务器中的所有topic
xxxxxxxxxx
bin/kafka-topics.sh --zookeeper node2,node3,node4:2181 --list
创建topic
xxxxxxxxxx
kafka-topics.sh --zookeeper node2:2181 --create --replication-factor 3 --partitions 1 --topic first
选项说明:
- --topic: 定义topic名
- --replication-factor: 定义副本数
- --partitions: 定义分区数
删除topic
xxxxxxxxxx
kafka-topics.sh --zookeeper node2:2181 --delete --topic first
发送消息
xxxxxxxxxx
kafka-console-producer.sh --broker-list node2:9092 --topic first
消费消息
xxxxxxxxxx
kafka-console-consumer.sh --zookeeper node2:2181 --topic first