kafka-topics.sh（kafkatopicssh zk认证）

## kafka-topics.sh：Kafka 主题管理利器### 简介`kafka-topics.sh` 是 Apache Kafka 提供的一个命令行工具，用于管理 Kafka 集群中的主题。它可以用来创建、修改、查看和删除主题，以及查看主题的详细信息，例如分区数、副本数和配置等。### 功能详解#### 1. 创建主题```bash kafka-topics.sh --bootstrap-server --create --topic --partitions --replication-factor ```

`--bootstrap-server`: 指定 Kafka Broker 的地址，可以是单个地址或多个地址用逗号分隔。

`--create`: 指示该命令用于创建主题。

`--topic`: 指定要创建的主题名称。

`--partitions`: 指定主题的分区数量。

`--replication-factor`: 指定主题的副本因子。

示例：

创建一个名为 "test-topic"，拥有 3 个分区和 2 个副本的主题：```bash kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test-topic --partitions 3 --replication-factor 2 ```#### 2. 查看主题列表```bash kafka-topics.sh --bootstrap-server --list ```

示例：

查看 Kafka 集群中所有的主题列表：```bash kafka-topics.sh --bootstrap-server localhost:9092 --list ```#### 3. 查看主题详情```bash kafka-topics.sh --bootstrap-server --describe --topic ```

示例：

查看主题 "test-topic" 的详细信息：```bash kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic test-topic ```#### 4. 修改主题配置```bash kafka-topics.sh --bootstrap-server --alter --topic --config = ```

`--alter`: 指示该命令用于修改主题配置。

`--config`: 指定要修改的配置项，例如 "cleanup.policy"，"retention.ms" 等。

示例：

将主题 "test-topic" 的消息保留时间设置为 1 天：```bash kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic test-topic --config retention.ms=86400000 ```#### 5. 删除主题```bash kafka-topics.sh --bootstrap-server --delete --topic ```

`--delete`: 指示该命令用于删除主题。

示例：

删除主题 "test-topic"：```bash kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic test-topic ```### 总结`kafka-topics.sh` 是一个功能强大的工具，可以方便地管理 Kafka 主题。了解其常用命令和参数，可以帮助开发者更高效地进行 Kafka 集群的运维工作。

kafka-topics.sh：Kafka 主题管理利器

简介`kafka-topics.sh` 是 Apache Kafka 提供的一个命令行工具，用于管理 Kafka 集群中的主题。它可以用来创建、修改、查看和删除主题，以及查看主题的详细信息，例如分区数、副本数和配置等。

功能详解

1. 创建主题```bash kafka-topics.sh --bootstrap-server --create --topic --partitions --replication-factor ```* `--bootstrap-server`: 指定 Kafka Broker 的地址，可以是单个地址或多个地址用逗号分隔。 * `--create`: 指示该命令用于创建主题。 * `--topic`: 指定要创建的主题名称。 * `--partitions`: 指定主题的分区数量。 * `--replication-factor`: 指定主题的副本因子。**示例：**创建一个名为 "test-topic"，拥有 3 个分区和 2 个副本的主题：```bash kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test-topic --partitions 3 --replication-factor 2 ```

2. 查看主题列表```bash kafka-topics.sh --bootstrap-server --list ```**示例：**查看 Kafka 集群中所有的主题列表：```bash kafka-topics.sh --bootstrap-server localhost:9092 --list ```

3. 查看主题详情```bash kafka-topics.sh --bootstrap-server --describe --topic ```**示例：**查看主题 "test-topic" 的详细信息：```bash kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic test-topic ```

4. 修改主题配置```bash kafka-topics.sh --bootstrap-server --alter --topic --config = ```* `--alter`: 指示该命令用于修改主题配置。 * `--config`: 指定要修改的配置项，例如 "cleanup.policy"，"retention.ms" 等。**示例：**将主题 "test-topic" 的消息保留时间设置为 1 天：```bash kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic test-topic --config retention.ms=86400000 ```

5. 删除主题```bash kafka-topics.sh --bootstrap-server --delete --topic ```* `--delete`: 指示该命令用于删除主题。**示例：**删除主题 "test-topic"：```bash kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic test-topic ```

总结`kafka-topics.sh` 是一个功能强大的工具，可以方便地管理 Kafka 主题。了解其常用命令和参数，可以帮助开发者更高效地进行 Kafka 集群的运维工作。