社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
步骤1:下载并解压zookeeper安装包
tar -zxvf zookeeper-3.4.11.tar.gz
步骤2:配置环境变量
export ZOOK=/opt/hadoop/zookeeper-3.4.11
步骤3:配置文件 zoo.cfg
cd conf/
复制配置文件:
cp zoo_sample.cfg zoo.cfg
修改配置文件:
#数据目录
dataDir=/home/admin/zookeeper/data
#日志目录
dataLogDir=/home/admin/zookeeper/logs
#心跳间隔时间,zookeeper中使用的基本时间单位,毫秒值。每隔2秒发送一个心跳
tickTime=2000
#leader与客户端连接超时时间。表示5个心跳间隔
initLimit=5
#Leader与Follower之间的超时时间,表示2个心跳间隔
syncLimit=2
#客户端连接端口
clientPort=2181
**启动zookeeper:
> bin/zkServer.sh start
**停止zookeeper:zkServer.sh stop
步骤1:下载并解压kafka
tar -xzvf kafka_2.11-1.0.0.tgz
步骤2:配置kafka,修改server.properties
mkdir /usr/local/kafka/log/kafka #创建kafka日志目录
cd /usr/local/kafka/config #进入配置目录
vi server.properties #编辑修改相应的参数
broker.id=0
port=9092 #端口号
host.name=10.8.5.101 #服务器IP地址,修改为自己的服务器IP
log.dirs=/usr/local/kafka/log/kafka #日志存放路径,上面创建的目录
zookeeper.connect=localhost:2181 #zookeeper地址和端口,单机配置部署,localhost:2181
步骤3、配置kafka下的zookeeper
mkdir /usr/local/kafka/zookeeper #创建zookeeper目录
mkdir /usr/local/kafka/log/zookeeper #创建zookeeper日志目录
cd /usr/local/kafka/config #进入配置目录
vi zookeeper.properties #编辑修改相应的参数
dataDir=/usr/local/kafka/zookeeper #zookeeper数据目录
dataLogDir=/usr/local/kafka/log/zookeeper #zookeeper日志目录
clientPort=2181
maxClientCnxns=100
tickTime=2000
initLimit=10
步骤4:启动zookeeper和kafka(可以在命令的结尾加个&符号,这样就可以启动后离开控制台)
> bin/zookeeper-server-start.sh config/zookeeper.properties &
>bin/kafka-server-start.sh config/server.properties &
步骤1:启动zookeeper
>bin/zookeeper-server-start.sh config/zookeeper.properties &
步骤2:启动kafka
>bin/kafka-server-start.sh config/server.properties &
步骤3:测试
创建kafka topic
bin/kafka-topics.sh --zookeeper node01:2181 --create --topic t_cdr --partitions 30 --replication-factor 2
注: partitions指定topic分区数,replication-factor指定topic每个分区的副本数
5、停止kafka
步骤1:停止Kafka
>bin/kafka-server-stop.sh config/server.properties
>bin/zookeeper-server-stop.sh config/zookeeper.properties
至此,启动,测试,停止全过程ok。
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!