• Kafka - kafka环境配置以及参数分析


    kafka安装配置

    首先下载zookeeper

    wget https://www.apache.org/dyn/closer.lua/zookeeper/zookeeper-3.7.1/apache-zookeeper-3.7.1-bin.tar.gz
    
    复制备份 zoo.cfg 文件
    
    • 1
    • 2
    • 3

    关于zookeepr的 配置文件参数分析参考:

    kafka下载

    wget https://downloads.apache.org/kafka/3.3.1/kafka_2.12-3.3.1.tgz
    
    • 1

    修改配置文件config/server.properties:

    #broker.id属性在kafka集群中必须要是唯一
    broker.id=0
    #kafka部署的机器ip和提供服务的端口号
    listeners=PLAINTEXT://node01:9092   
    #kafka的消息存储文件
    log.dir=/soft/kafka/logs
    #kafka连接zookeeper的地址
    zookeeper.connect=node01:2181
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    listeners: 可以配置安全连接配置 
    listeners=SSL://node01:9092  
    
    • 1
    • 2
    PropertyDefaultDescription
    broker.id00每个broker都可以用一个唯一的非负整数id进行标识;这个id可以作为broker的“名字”,你可以选择任意你喜欢的数字作为id,只要id是唯一的即可。
    log.dirs/tmp/kafka-logskafka存放数据的路径。这个路径并不是唯一的,可以是多个,路径之间只需要使用逗号分隔即可;每当创建新partition时,都会选择在包含最少partitions的路径下进行
    listenersPLAINTEXT://192.168.65.60:9092server接受客户端连接的端口,ip配置kafka本机ip即可
    zookeeper.connectlocalhost:2181zooKeeper连接字符串的格式为:hostname:port,此处hostname和port分别是ZooKeeper集群中某个节点的host和port;zookeeper如果是集群,连接方式为 hostname1:port1, hostname2:port2, hostname3:port3
    log.retention.hours168每个日志文件删除之前保存的时间。默认数据保存时间对所有topic都一样。
    num.partitions1topic分区
    default.replication.factor1自动创建topic的默认副本数量,建议设置为大于等于2
    min.insync.replicas1当producer设置acks为-1时,min.insync.replicas指定replicas的最小数目(必须确认每一个repica的写数据都是成功的),如果这个数目没有达到,producer发送消息会产生异常
    delete.topic.enablefalse是否允许删除主题

    配置案例:

    #broker 的全局唯一编号,不能重复,只能是数字。
    broker.id=0
    #处理网络请求的线程数量
    num.network.threads=3
    #用来处理磁盘 IO 的线程数量
    num.io.threads=8
    #发送套接字的缓冲区大小
    socket.send.buffer.bytes=102400
    #接收套接字的缓冲区大小
    socket.receive.buffer.bytes=102400
    #请求套接字的缓冲区大小
    socket.request.max.bytes=104857600
    #kafka 运行日志(数据)存放的路径,路径不需要提前创建,kafka 自动帮你创建,可以
    配置多个磁盘路径,路径与路径之间可以用","分隔
    log.dirs=/opt/module/kafka/datas
    #topic 在当前 broker 上的分区个数
    num.partitions=1
    #用来恢复和清理 data 下数据的线程数量
    num.recovery.threads.per.data.dir=1
    # 每个 topic 创建时的副本数,默认时 1 个副本
    offsets.topic.replication.factor=1
    #segment 文件保留的最长时间,超时将被删除
    log.retention.hours=168
    #每个 segment 文件的大小,默认最大 1G
    log.segment.bytes=1073741824
    # 检查过期数据的时间,默认 5 分钟检查一次是否数据过期
    log.retention.check.interval.ms=300000
    #配置连接 Zookeeper 集群地址(在 zk 根目录下创建/kafka,方便管理)
    zookeeper.connect=node01:2181
    
    • 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
    • 27
    • 28
    • 29
  • 相关阅读:
    微信小程序开发之图片压缩方案
    为什么Move将超越Solidity成为主流编程语言?
    房地产数字化转型方案:全方位数智化系统运营,助力房企管控实效提升
    【MRTK】HoloLens 项目部署的几种方法
    Spring Boot如何进行单元测试呢?
    leetcode/求平方根
    【Android知识笔记】FrameWork中的设计模式
    【前后缀 + 推公式整理】 Codeforces Round #813 (Div. 2) D. Empty Graph
    文件属性之文件权限
    【熵与特征提取】从近似熵,到样本熵,到模糊熵,再到排列熵,包络熵,散布熵,究竟实现了什么?(第六篇)——“散布熵”及其MATLAB实现
  • 原文地址:https://blog.csdn.net/huanglu0314/article/details/128165978