kafka入门(2)- 环境部署

部署Zookeeper(单机/集群)

1、下载安装文件: http://mirror.bit.edu.cn/apache/zookeeper/ 
2、解压文件(本文解压到 D:\zookeeper-3.4.8) 
3、打开D:\zookeeper-3.4.8\conf,把zoo_sample.cfg重命名成zoo.cfg 
4、从文本编辑器里打开zoo.cfg 
5、修改dataDir和dataLogDir保存路径

dataDir=F:/2018_INTERVIEW/data/zookeeper/data
dataLogDir=F:/2018_INTERVIEW/data/zookeeper/log

6、启动bin/zkServer.cmd

kafka入门(2)- 环境部署

ps:集群只需要多配置其他机器的信息

server.1=192.168.0.1:3888:4888
server.2=192.168.0.2:3888:4888
server.3=192.168.0.3:3888:4888

部署Kafka(单机/集群)

1、下载安装文件: http://kafka.apache.org/downloads.html 
2、解压文件(本文解压到 D:\kafka_2.11-0.10.2.0) 
3、打开D:\kafka_2.11-0.10.2.0\config\ server.properties 
4、把 log.dirs的值改成 log.dirs=D:\data\logs\kafka 
5、D:\kafka_2.11-0.10.2.0\bin文件夹下的.sh命令脚本是在shell下运行的,此文件夹下还有个 windows文件夹,里面是windows下运行的.bat命令脚本 
6、在D:\kafka_2.11-0.10.2.0文件夹中”Shift+鼠标右键”点击空白处打开命令提示窗口

切换到bin目录,执行 kafka-server-start.bat ../../config/server.properties

kafka入门(2)- 环境部署

ps:集群只需要多配置其他机器的信息

   broker.id=1 #个集群中的唯一标识,且只能是正整数
port=9091
num.network.threads=2
num.io.threads=2
socket.send.buffer.bytes=1048576
socket.receive.buffer.bytes=1048576
socket.request.max.bytes=104857600
log.dir=./
logs
num.partitions
=2
log.flush.interval.messages=10000
log.flush.interval.ms=1000
log.retention.hours=168
#log.retention.bytes=1073741824
log.segment.bytes=536870912
num.replica.fetchers=2

log.cleanup.interval.mins=10
zookeeper.connect=192.168.0.1:2181,192.168.0.2:2182,192.168.0.3:2183

zookeeper.connection.timeout.ms=1000000
kafka.metrics.polling.interval.secs=5
kafka.metrics.reporters=kafka.metrics.KafkaCSVMetricsReporter
kafka.csv.metrics.dir=/tmp/kafka_metrics
kafka.csv.metrics.reporter.enabled=false
上一篇:RPC框架之Thrift分析(转)


下一篇:android studio中为项目添加依赖包的方法