Kafka配置文件Ubuntu怎么改 - 问答

在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 赞

0 踩