栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

linux安装kafka

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

linux安装kafka

安装包地址

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 
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/992025.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号