前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Zookeeper、kafka部署

Zookeeper、kafka部署

作者头像
itliusir
发布2018-05-21 16:59:32
8680
发布2018-05-21 16:59:32
举报
文章被收录于专栏:刘君君刘君君

正文:

安装zookeeperkafka

解压zk安装包

代码语言:javascript
复制
tar -zxvf zookeeper-3.4.10.tar.gz

添加系统环境变量

vim /etc/profile尾部追加

代码语言:javascript
复制
export ZOOKEEPER_HOME=/software/zookeeper-3.4.10/
export PATH=$ZOOKEEPER_HOME/bin:$PATH
export PATH

输入source /etc/profile重新加载系统环境变量

修改zookeeper配置文件

代码语言:javascript
复制
[root@server28 zookeeper-3.4.10]# cd conf/
[root@server28 conf]# cp zoo_sample.cfg zoo.cfg
[root@server28 conf]# ls
configuration.xsl  log4j.properties  zoo.cfg  zoo_sample.cfg

修改zoo.cfg

代码语言:javascript
复制
# 服务器与客户端之间交互的基本时间单元(ms)
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# 配置保存数据文件夹
dataDir=/software/zookeeper-3.4.10/data
# 配置保存日志文件夹,当此配置不存在时默认路径与dataDir一致
dataLogDir=/software/zookeeper-3.4.10/logs
# 客户端访问zookeeper的端口号
clientPort=2181

启动、关闭zookeeper

  • 启动服务
代码语言:javascript
复制
[root@server28 bin]# ./zkServer.sh start
ZooKeeper JMX enabled by default
Using config: /software/zookeeper-3.4.10/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
  • 关闭服务
代码语言:javascript
复制
[root@server28 bin]# ./zkServer.sh stop
ZooKeeper JMX enabled by default
Using config: /software/zookeeper-3.4.10/bin/../conf/zoo.cfg
Stopping zookeeper ... STOPPED
  • 重启服务
代码语言:javascript
复制
[root@server28 bin]# ./zkServer.sh restart
ZooKeeper JMX enabled by default
Using config: /software/zookeeper-3.4.10/bin/../conf/zoo.cfg
ZooKeeper JMX enabled by default
Using config: /software/zookeeper-3.4.10/bin/../conf/zoo.cfg
Stopping zookeeper ... STOPPED
ZooKeeper JMX enabled by default
Using config: /software/zookeeper-3.4.10/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED

解压kafka安装包

代码语言:javascript
复制
tar -zxvf kafka_2.11-0.10.1.1.tgz
mv kafka_2.11-0.10.1.1 kafka
cd kafka
cp config/server.properties bin

启动kafka服务

代码语言:javascript
复制
# 后台启动
[root@server28 bin]# ./kafka-server-start.sh -daemon server.properties

检查

代码语言:javascript
复制
[root@server28 bin]# jps
31523 Jps
1332 jenkins.war
31032 QuorumPeerMain
31224 Kafka

删除Topic

删除Kafka的topic

代码语言:javascript
复制
1.如果kafka启动时加载的配置文件server.properties没有配置delete.topic.enable = true这条命令并不执行删除动作,仅仅是在zookeeper上标记该topic要被删除,需要往下执行.
[root@server28 bin]# ./kafka-topics.sh -delete -zookeeper 192.168.103.28:2181 -topic mic-service
Topic mic-service is already marked for deletion.
2.从kafka manager去删除

stop Kafka

代码语言:javascript
复制
[root@server28 bin]# ./kafka-server-stop.sh server.properties
[root@server28 bin]# jps
23792 Jps
1332 jenkins.war
31032 QuorumPeerMain

删除Kafka的log

代码语言:javascript
复制
在配置文件找到kafka日志目录并删除对应目录,这里是全部清空
[root@server28 tmp]# cd kafka-logs/
[root@server28 tmp]# rm -rf *

删除Zookeeper下节点

代码语言:javascript
复制
[root@server28 bin]# zkCli.sh -server 192.168.103.28:2181
[zk: 192.168.103.28:2181(CONNECTED) 0] rmr /admin/delete_topics/mic-service
[zk: 192.168.103.28:2181(CONNECTED) 1] rmr /brokers/topics/mic-service
[zk: 192.168.103.28:2181(CONNECTED) 2] rmr /config/topics/mic-service
[zk: 192.168.103.28:2181(CONNECTED) 3] ls /admin/delete_topics
[]
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2018-04-13,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 正文:
  • 安装zookeeper、kafka
    • 解压zk安装包
      • 添加系统环境变量
        • 修改zookeeper配置文件
          • 启动、关闭zookeeper
            • 解压kafka安装包
              • 启动kafka服务
                • 检查
                  • 删除Topic
                    • 删除Kafka的topic
                    • stop Kafka
                    • 删除Kafka的log
                    • 删除Zookeeper下节点
                领券
                问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档