温馨提示×

Kafka配置文件Ubuntu怎么改

小樊
58
2025-04-10 10:24:27
栏目: 智能运维

在Ubuntu上修改Kafka配置文件主要分为以下几个步骤:

1. 修改Kafka的配置文件

  • 找到配置文件的位置

    vi ./kafka_2.13-2.8.0/config/server.properties 

    这里的kafka_2.13-2.8.0应替换为你实际安装的Kafka版本路径。

  • 修改配置项

    • broker.id:默认值为-1,只有大于等于0的时候,才会正常启动。
    • port:设置为当前Kafka的端口,例如9000。
    • host.name:单机可直接用localhost
    • log.dirs:设置为保存日志的地方,需要新建一个文件夹,例如/home/XXX/kafka_2.13-2.8.0/logs
    • zookeeper.connect:设置为Zookeeper的连接IP和端口,例如localhost:2181

2. 修改ZooKeeper配置

  • 找到配置文件的位置

    vi ./kafka_2.13-2.8.0/config/zookeeper.properties 
  • 修改配置项

    • dataDir:设置为Zookeeper数据储存的位置,例如/home/XXX/kafka/zookeeper/data
    • dataLogDir:设置为Zookeeper日志储存的位置,例如/home/XXX/kafka/zookeeper/logs
    • clientPort:设置为Zookeeper的端口,例如2181。
    • maxClientCnxns:设置最大的连接数。
    • tickTime:设置为Zookeeper服务器之间或客户端之间维持心跳的时间间隔,例如2000毫秒。
    • initLimit:设置为Zookeeper接受客户端初始化连接时,最长能忍受多少个心跳时间间隔。

3. 创建必要的文件夹

  • 创建日志文件夹:
    mkdir /home/XXX/kafka_2.13-2.8.0/logs 
  • 创建Zookeeper文件夹及其子文件夹:
    mkdir /home/XXX/kafka_2.13-2.8.0/zookeeper mkdir /home/XXX/kafka_2.13-2.8.0/zookeeper/data mkdir /home/XXX/kafka_2.13-2.8.0/zookeeper/logs 

4. 启动Kafka

  • 创建启动脚本

    touch /home/XXX/kafka_2.13-2.8.0/kafka_start.sh chmod +x /home/XXX/kafka_2.13-2.8.0/kafka_start.sh 
  • 编写启动脚本内容

    #!/bin/bash # 先启动Zookeeper /home/XXX/kafka_2.13-2.8.0/bin/zookeeper-server-start.sh /home/XXX/kafka_2.13-2.8.0/config/zookeeper.properties & sleep 3 # 后启动Kafka /home/XXX/kafka_2.13-2.8.0/bin/kafka-server-start.sh /home/XXX/kafka_2.13-2.8.0/config/server.properties & 
  • 执行启动脚本

    sh /home/XXX/kafka_2.13-2.8.0/kafka_start.sh 

5. 关闭Kafka

  • 创建停止脚本

    touch /home/XXX/kafka_2.13-2.8.0/kafka_stop.sh chmod +x /home/XXX/kafka_2.13-2.8.0/kafka_stop.sh 
  • 编写停止脚本内容

    #!/bin/bash /home/XXX/kafka_2.13-2.8.0/bin/kafka-server-stop.sh sleep 3 /home/XXX/kafka_2.13-2.8.0/bin/zookeeper-server-stop.sh 
  • 执行停止脚本

    sh /home/XXX/kafka_2.13-2.8.0/kafka_stop.sh 

6. 创建和测试Topic

  • 创建Topic
    ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic MyTopic 
  • 测试生产者
    ./kafka-console-producer.sh --broker-list localhost:9000 --topic MyTopic 
  • 测试消费者
    ./kafka-console-consumer.sh --bootstrap-server localhost:9000 --topic MyTopic --from-beginning 

以上步骤涵盖了在Ubuntu上修改Kafka配置文件的基本流程,具体版本可能会有所不同,请根据实际情况进行调整。

0