标签：topic 01 zookeeper kafka CentOS7 sh 0.11 2.12
kafka是大数据组件中的消息队列，俗语有云：系统卡不卡，全看kafka。kafka的使用能极大的提升的系统吞吐量。本文将阐述在CentOS7中安装kafka。
1 系统、软件以及前提约束
- CentOS 7 64 工作站 作者的机子ip是192.168.100.200，请读者根据自己实际情况设置
- jdk1.8.0_162 已经安装完毕，并配置环境变量，作者的环境变量为/root/jdk1.8.0_162，请读者根据自己实际情况设置
jdk安装 https://www.jianshu.com/p/08b94347bb8a - zookeeper已经安装完毕
https://www.jianshu.com/p/45e84fc9d02f - kafka_2.12-0.11.0.2
kafka下载链接：https://pan.baidu.com/s/1c_skDYabCRSkS5hRUB6lFQ
提取码：a00t
kafka_2.12-0.11.0.2.tgz已上传到192.168.100.200的/root目录下 - xshell客户端
- 为去除权限对操作的影响，所有操作都以root进行
2 操作
- 1 使用xshell登录到192.168.100.200
- 2 解压kafka_2.12-0.11.0.2.tgz
# 进入家目录
cd
# 解压
tar -xvf kafka_2.12-0.11.0.2.tgz
- 3 启动服务、创建topic、启动生产者和消费者
# 确保没有其他程序占用2181端口，启动服务
cd /root/kafka_2.12-0.11.0.2/bin
./zookeeper-server-start.sh ../config/zookeeper.properties &
./kafka-server-start.sh ../config/server.properties &
# 创建topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test &
# 查看创建的topic
./kafka-topics.sh --list --zookeeper localhost:2181
# 启动生产者
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
# 再打开一个窗口，登录，进入kafka启动目录，启动消费者
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
- 4 测试
在生产者窗口输入子串，在消费者窗口观察输出。
以上就是在CentOS7中测试你kafka的生产者、消费者之间的消息传输。
标签：topic,01,zookeeper,kafka,CentOS7,sh,0.11,2.12 来源： https://www.cnblogs.com/alichengxuyuan/p/12576866.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。