zoukankan      html  css  js  c++  java
  • kafka不停止服务的情况下修改日志保留时间

    kafka配置文件如下:

    broker.id=1
    port=9092
    host.name=ssy-kafka1
    num.network.threads=4
    
    num.io.threads=8
    socket.send.buffer.bytes=1048576
    socket.receive.buffer.bytes=1048576
    socket.request.max.bytes=104857600
    log.dirs=/data/apps/log/kafka
    num.partitions=20
    log.retention.hours=72    #定义日志保留时间
    log.segment.bytes=536870912
    log.retention.check.interval.ms=60000
    log.cleaner.enable=true
    
    zookeeper.connect=ssy-zk1:2181,ssy-zk2:2181,ssy-zk3:2181
    
    zookeeper.connection.timeout.ms=1000000
    auto.create.topics.enable=true
    controlled.shutdown.enable=true
    auto.leader.rebalance.enable=true
    

      很多情况下,kafka会占用大量的磁盘空间来存放日志文件,我们默认保存三天,如果磁盘已经不允许我们继续写日志可以执行以下命令在不必停止kafka服务的情况下执行以下命令。
    ./kafka-topics.sh --zookeeper zk1:2181 -topic topicname --alter --config retention.ms=86400 将此Topic的日志保存时间设置为1天。

  • 相关阅读:
    webpack 学习
    文件操作
    关于列表remove的操作和字符串split的操作新领悟
    深浅拷贝和基础类型补充
    小数据池和编码
    字典和集合
    列表和元组
    字符串理论
    递归遍历多层列表
    基本数据类型和操作
  • 原文地址:https://www.cnblogs.com/Cherry-Linux/p/7715044.html
Copyright © 2011-2022 走看看