文档章节

kafka集群搭建

jwyming
 jwyming
发布于 2017/04/26 10:31
字数 198
阅读 22
收藏 0

Kafka配置

tar xvf kafka_2.12-0.10.2.0.tar

vi config/server.properties:

broker.id=0   #每个服务器的broker.id应该不同
zookeeper.connect=192.168.70.103:2181,192.168.70.104:2181,192.168.70.105:2181

拷贝配置好后的kafka_2.12-0.10.2.0目录到每个要部署的服务器上,修改broker.id的值。

启动Kafka

在每个服务器上执行:

cd /opt/kafka_2.12-0.10.2.0/bin

./kafka-server-start.sh -daemon ../config/server.properties

执行 jps命令检查服务是否有Kafka进程已经启动

验证Kafka服务

#创建Topic
./kafka-topics.sh --create --zookeeper 192.168.70.103:2181,192.168.70.104:2181,192.168.70.105:2181 --replication-factor 2 --partitions 1 --topic yimingTest


#创建一个broker发布者
./kafka-console-producer.sh --broker-list 192.168.70.104:9092,192.168.70.105:9092,192.168.70.103:9092 --topic yimingTest

# 在另一台服务器上创建一个订阅者
./kafka-console-consumer.sh --bootstrap-server 192.168.70.103:2181,192.168.70.104:2181,192.168.70.105:2181 --topic yimingTest --from-beginning

#显示我们创建的所有topic
./kafka-topics.sh --list --zookeeper 192.168.70.103:2181,192.168.70.104:2181,192.168.70.105:2181

#显示topic详细信息
/kafka-topics.sh --describe --zookeeper 192.168.70.103:2181,192.168.70.104:2181,192.168.70.105:2181  --topic yimingTest

 

© 著作权归作者所有

下一篇: Hive 2.1.1 安装
jwyming
粉丝 1
博文 11
码字总数 2958
作品 0
程序员
私信 提问

暂无文章

DDD(五)

1、引言 之前学习了解了DDD中实体这一概念,那么接下来需要了解的就是值对象、唯一标识。值对象,值就是数字1、2、3,字符串“1”,“2”,“3”,值时对象的特征,对象是一个事物的具体描述...

MrYuZixian
今天
6
0
数据库中间件MyCat

什么是MyCat? 查看官网的介绍是这样说的 一个彻底开源的,面向企业应用开发的大数据库集群 支持事务、ACID、可以替代MySQL的加强版数据库 一个可以视为MySQL集群的企业级数据库,用来替代昂贵...

沉浮_
今天
4
0
解决Mac下VSCode打开zsh乱码

1.乱码问题 iTerm2终端使用Zsh,并且配置Zsh主题,该主题主题需要安装字体来支持箭头效果,在iTerm2中设置这个字体,但是VSCode里这个箭头还是显示乱码。 iTerm2展示如下: VSCode展示如下: 2...

HelloDeveloper
今天
6
0
常用物流快递单号查询接口种类及对接方法

目前快递查询接口有两种方式可以对接,一是和顺丰、圆通、中通、天天、韵达、德邦这些快递公司一一对接接口,二是和快递鸟这样第三方集成接口一次性对接多家常用快递。第一种耗费时间长,但是...

程序的小猿
今天
7
0
Python机器学习之数据探索可视化库yellowbrick

背景介绍 从学sklearn时,除了算法的坎要过,还得学习matplotlib可视化,对我的实践应用而言,可视化更重要一些,然而matplotlib的易用性和美观性确实不敢恭维。陆续使用过plotly、seaborn,...

yeayee
今天
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部