kafka重启 ./kafka-server-start.sh config/
时间: 2023-08-20 10:09:04 浏览: 440
您好!对于重启 Kafka,您可以执行以下命令:
```shell
./kafka-server-start.sh config/server.properties
```
上述命令假设 `kafka-server-start.sh` 脚本和 `config/server.properties` 配置文件位于当前工作目录下。请确保您已进入正确的 Kafka 安装目录,并根据您的实际情况修改路径。
执行该命令后,Kafka 服务器将以指定的配置文件重新启动。请注意,如果您对配置进行了更改,这些更改将在重启后生效。
相关问题
./kafka-server-start.sh ../config/server.properties > /dev/null 2>&1 & 含义
这个命令是用于在 Linux 系统上启动 Kafka 服务器的,含义如下:
- `./kafka-server-start.sh ../config/server.properties`:这个部分是启动 Kafka 服务器的命令。`kafka-server-start.sh` 脚本用于启动 Kafka 服务器,`../config/server.properties` 指定了 Kafka 服务器的配置文件的路径。这个命令会将 Kafka 服务器启动,并将所有输出信息(包括标准输出和标准错误输出)输出到后面的重定向符中。
- `> /dev/null`:这个部分将标准输出重定向到 `/dev/null`,即将所有标准输出信息丢弃,不再显示在终端上。
- `2>&1`:这个部分将标准错误输出重定向到标准输出,即将所有的标准错误输出信息输出到标准输出中。由于标准输出已经被重定向到 `/dev/null`,所以标准错误输出信息也被丢弃了。
- `&`:这个部分将整个命令放入后台运行,并立即返回终端,不会阻塞当前终端。这样,Kafka 服务器就会在后台一直运行,直到手动停止或者系统重启。
综合起来,这个命令的作用是启动 Kafka 服务器,将所有的输出信息都丢弃,同时将 Kafka 服务器放入后台运行。常见的用法是在生产环境中启动 Kafka 服务器。
#! /bin/bash if [ $# -lt 1 ] then echo "Usage: kf.sh {start|stop|kc [topic]|kp [topic] |list |delete [topic] |describe [topic]}" exit fi case $1 in "start") for i in sgghadoop102 sgghadoop103 sgghadoop104 do echo "============> Start $i Kafka <============" ssh $i "/opt/module/kafka_2.11-2.4.1/bin/kafka-server-start.sh -daemon /opt/module/kafka_2.11-2.4.1/config/server.properties" done ;; "stop") for i in sgghadoop102 sgghadoop103 sgghadoop104 do echo "============> Stop $i Kafka <============" ssh $i "/opt/module/kafka_2.11-2.4.1/bin/kafka-server-stop.sh stop" done ;; "kc") if [ $2 ] then kafka-console-consumer.sh --bootstrap-server sgghadoop102:9092,sgghadoop103:9092,sgghadoop104:9092 --topic $2 else echo "Usage: kf.sh {start|stop|kc [topic]|kp [topic] |list |delete [topic] |describe [topic]}" fi ;;
这段代码是一个 Bash 脚本,用于启动、停止、查看 Kafka 集群中的 topic 等操作。其中,start 命令会通过 ssh 命令在 sgghadoop102、sgghadoop103 和 sgghadoop104 上启动 Kafka 服务;stop 命令会在这三个节点上停止 Kafka 服务;kc 命令用于查看指定 topic 的消息,需要指定 topic 名称作为第二个参数。另外,脚本还提供了 kp、list、delete 和 describe 命令,分别用于生产消息、查看 topic 列表、删除 topic 和查看 topic 的详细信息。需要注意的是,这个脚本需要在安装了 Kafka 的服务器上执行,并且需要按照实际情况修改脚本中的节点名称和 Kafka 安装路径。
阅读全文