Kafka集群安装--测试--关闭
一、前提
1、kafka安装包下载:http://kafka.apache.org/downloads
2、jdk已安装
3、scala已安装
4、zookeeper集群已安装并运行
二、步骤
1、对kafka_2.9.2-0.8.1.tgz进行解压缩:tar -zxvf kafka_2.9.2-0.8.1.tgz。
2、对kafka目录进行改名:mv kafka_2.9.2-0.8.1 kafka
3、配置kafka
vi /usr/local/kafka/config/server.properties
broker.id:依次增长的整数,0、1、2、3、4,集群中Broker的唯一id
zookeeper.connect=192.168.1.107(BD01):2181,192.168.1.108:2181,192.168.1.109:2181
(用域名更好,万一测试环境ip地址变了,可以不用改配置)
三、启动
#从后台启动Kafka集群(3台都需要启动)
cd /opt/kafka/kafka_2.11-0.9.0.1//bin#进入到kafka的bin目录
./kafka-server-start.sh -daemon ../config/server.properties
四、测试
集群中任选一台,如BD03,进入kafka\bin文件夹下
输入命令
#创建主题
./kafka-topics.sh --zookeeper BD03:2181,BD04:2181,BD05:2181 --topic TestTopic --replication-factor 1 --partitions 1 --create
集群中任选一台,如BD04,进入kafka\bin文件夹下
输入命令
#创建生产者
./kafka-console-producer.sh --broker-list BD03:9092,BD04:9092,BD05:9092 --topic TestTopic
集群中任选一台,如BD05,进入kafka\bin文件夹下
输入命令
#创建消费者
./kafka-console-consumer.sh --zookeeper BD03:2181,BD04:2181,BD05:2181 --topic TestTopic --from-beginning
----------------
BD04 生产者
BD05 消费者
五、关闭
以下参考了:http://blog.csdn.net/M_SIGNALs/article/details/53201595
似乎有一个是用来关闭服务的,”kafka-server-stop.sh“,于是我们运行这个脚本:
[root@master bin]# kafka-server-stop.sh
No kafka server to stop[root@master bin]#
- 1
- 2
- 3
- 4
what ? 没有服务要被关闭?我们可以看一下这个脚本到底是怎么写的,是不是我们的参数不正确还是怎么滴。
[root@master bin]# cat kafka-server-stop.sh
#!/bin/sh
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
PIDS=$(ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}')if [ -z "$PIDS" ]; thenecho "No kafka server to stop"exit 1
else kill -s TERM $PIDS
fi[root@master bin]#
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
好吧,这么看来也就是我们用这样的方法是不行了。干脆直接 kill -9
[root@master kafka_2.11-0.10.1.0]# jps
3448 Kafka
2136 NodeManager
3033 QuorumPeerMain
1772 DataNode
5757 Jps
3711 Kafka
[root@master kafka_2.11-0.10.1.0]# kill -9 3448
...
[1]- Killed kafka-server-start.sh server4.properties
...
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
就是这么简单粗暴。
Kafka集群安装--测试--关闭相关推荐
- KafKa集群安装、配置
一.事前准备 1.kafka官网:http://kafka.apache.org/downloads. 2.选择使用版本下载. 3.kafka集群环境准备:(linux) 192.168.145.12 ...
- zookeeper+kafka集群安装之中的一个
zookeeper+kafka集群安装之中的一个 准备3台虚拟机, 系统是RHEL64服务版. 1) 每台机器配置例如以下: $ cat /etc/hosts ... # zookeeper host ...
- Kafka集群安装Version2.10
Kafka集群安装,基于版本2.10, 使用kafka_2.10-0.10.1.0.tgz安装包. 1.安装规划 Storm集群模式,安装到下面三台机器 IP Hostname 10.43.159.2 ...
- Kafka 集群安装
一.集群准备 node1 192.168.157.128 node1 192.168.157.129 node1 192.168.157.130 二.安装zookeeper集群 Zookeeper 集 ...
- Kafka集群安装Version1.0.1(自带Zookeeper)
1.说明 Kafka集群安装,基于版本1.0.1, 使用kafka_2.12-1.0.1.tgz安装包, 其中2.12是编译工具Scala的版本. 而且不需要另外安装Zookeeper服务, 使用Ka ...
- apisix集群安装测试
apisix集群安装测试 apisix 是无状态服务,集群不用太复杂 本次测试使用在集群外做负载均衡 集群地址 172.21.41.240 172.21.41.241 172.21.41.242 版本 ...
- centos7搭建Linux集群,CentOS 7下Kafka集群安装
一.环境操作系统和软件版本介绍 1.环境操作系统为CentOS Linux release 7.2.1511 (Core) 可用cat /etc/RedHat-release查询 2.软件版本 Kaf ...
- kafka集群安装部署
Apache Kafka 是一个高吞吐量分布式消息系统,由LinkedIn开源.引用官网对kafka的介绍:"Apache Kafka is publish-subscribe messag ...
- win10下kafka集群安装+集成springboot
kafka安装+集成springboot 记录kafka安装.学习.继承springboot的过程 文章目录 kafka安装+集成springboot 前言 一.kafka + zk的安装 1.zk的 ...
最新文章
- 华为交换机SSH登录失败原因
- 用 Arthas “庖丁解牛”
- Qt Creator 最实用的快捷操作
- Head first servlet and jsp学习笔记
- 《软件项目管理(第二版)》第 7 章——项目风险管理 重点部分总结
- [转]远远走来一个绿茶婊
- 57 Insert Interval
- 关于基础类数据结构的设计想法
- lldp协议代码阅读_LLDPD协议验证过程记录
- Linux学习笔记(五) -- Linux+Anjuta搭建C++开发环境
- 联邦贸易委员会:大数据带来的歧视风险
- ODBC连接数据库使用动态密码
- 【VR】一直困扰虚拟现实的VAC现象,真的无解么?
- jarvisoj_level1
- 国内外最好用的6款Bug跟踪管理软件,测试员不可不知!
- 微软雅黑html中怎么写,css样式怎么设置字体为微软雅黑?
- 知乎这样的内容社区,如何做好 AI 架构搭建与应用?
- 浙大845控制考研经验贴(21上岸)
- Adope flash player ActiveX10安装文件Flash10l.ocx手动注册后不能被删除的解决方案
- PPTP、L2F、L2TP协议
热门文章
- autojs调用java识字_autojs实现抽象类的继承
- java 审批流_一文读懂工作流
- java中线程调度遵循的原则_深入理解Java多线程核心知识:跳槽面试必备
- ios 不被遮挡 阴影_IOS开发之Bug--iOS7View被导航栏遮挡问题的解决
- html form callback,Promise异步编程模式总结初始化Promise对象统一错误处理PromisifyfromCallbackMongoose Promisify...
- 将你一张表的值覆盖_山西联通携手华为完成长风商务区宏微协同,立体覆盖,打造5G精品网络...
- java日期函数精确到日,java日期时间函数分享
- 知识蒸馏 knowledge distill 相关论文理解
- Loadrunner的基本概念
- 1607: 字符棱形