https://kafka.apache.org/downloads
安装步骤 上传安装包到服务器(博主是/home/admin/local/) 解压tar -xvf kafka_2.12-1.0.0.tgz创建目录
mkdir -p /home/admin/local/kafka_2.12-1.0.0/tmp/kafka-log修改配置文件
vi config/server.properties
下方是文件内容
#需修改为对应的唯一数字,标示当前server在集群中的id,从0开始 broker.id=0 #是否允许删除topic delete.topic.enable=true # broker服务器要监听的地址及端口.集群模式必须开启;默认是 localhost:9092 ,0.0.0.0的话 ,表示监听本机的所有ip地址. listeners=PLAINTEXT://0.0.0.0:9092 num.network.threads=5 num.io.threads=10 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 # kafka数据保存路径 log.dirs=/home/admin/local/kafka_2.12-1.0.0/tmp/kafka-log/ num.partitions=6 default.replication.factor=1 num.recovery.threads.per.data.dir=1 offsets.topic.replication.factor=1 transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1 # 日志保存时间,168小时 log.retention.hours=168 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 # zk地址,集群环境使用逗号分隔 zookeeper.connect=ip:2181 zookeeper.connection.timeout.ms=6000 group.initial.rebalance.delay.ms=0启动服务
cd /home/admin/local nohup kafka_2.12-1.0.0/bin/kafka-server-start.sh kafka_2.12-1.0.0/config/server.properties &创建Kafka的Partitions
kafka topic默认会通过相关应用kafka客户端自动创建,创建配置replication-factor,partitions会基于上述配置文件
查看Kafka的Partitions# 替换成实际的zk地址 cd /home/admin/local kafka_2.12-1.0.0/bin/kafka-topics.sh -zookeeper ip:2181 -list kafka_2.12-1.0.0/bin/kafka-topics.sh -zookeeper ip:2181 -describe



