kafka命令大全（kafka用法）

## Kafka 命令大全### 简介Kafka 是一个分布式流处理平台，提供了高吞吐量、低延迟的消息发布和订阅系统。Kafka 命令行工具是与 Kafka 集群交互的主要方式，用于管理和检查 brokers、topics、partitions 等资源。### 常用命令#### 1. 主题管理-

创建主题:

```bashkafka-topics.sh --bootstrap-server --create --topic --partitions --replication-factor ```- `--bootstrap-server`: Kafka broker 地址列表- `--topic`: 主题名称- `--partitions`: 分区数量- `--replication-factor`: 副本因子-

列出主题:

```bashkafka-topics.sh --bootstrap-server --list```-

描述主题:

```bashkafka-topics.sh --bootstrap-server --describe --topic ```- 查看主题详细信息，例如分区、副本、leader 等-

删除主题:

```bashkafka-topics.sh --bootstrap-server --delete --topic ```#### 2. 生产者命令-

发送消息:

```bashkafka-console-producer.sh --bootstrap-server --topic ```- 启动控制台生产者，输入消息并发送到指定主题-

指定key发送消息:

```bashkafka-console-producer.sh --bootstrap-server --topic --property parse.key=true --property key.separator=":"```- 启动控制台生产者，并设置`parse.key=true`和分隔符发送key-value消息，例如`key:value`#### 3. 消费者命令-

消费消息:

```bashkafka-console-consumer.sh --bootstrap-server --topic ```- 启动控制台消费者，从指定主题消费消息-

从指定偏移量消费:

```bashkafka-console-consumer.sh --bootstrap-server --topic --offset ```- `--offset`: 指定消费起始偏移量-

消费指定时间段的消息:

```bashkafka-console-consumer.sh --bootstrap-server --topic --from-beginning --property print.timestamp=true --max-messages ```- `--from-beginning`: 从头开始消费- `--property print.timestamp=true`: 打印消息时间戳- `--max-messages`: 指定消费消息数量#### 4. 其他常用命令-

查看消费者组:

```bashkafka-consumer-groups.sh --bootstrap-server --list```-

描述消费者组:

```bashkafka-consumer-groups.sh --bootstrap-server --describe --group ```- `--group`: 消费者组ID-

删除消费者组:

```bashkafka-consumer-groups.sh --bootstrap-server --delete --group ```-

查看集群信息:

```bashkafka-topics.sh --describe --zookeeper ```### 高级命令除了以上常用命令，Kafka 还提供了一些高级命令，用于更精细化的管理和操作，例如：

`kafka-configs.sh`：管理 Kafka broker 配置

`kafka-reassign-partitions.sh`: 重新分配分区

`kafka-preferred-replica-election.sh`: 手动触发 Preferred Leader 选举### 总结本文介绍了 Kafka 常用命令，涵盖了主题管理、生产者、消费者和一些其他常用操作。熟练掌握这些命令可以帮助你更好地管理和使用 Kafka 集群。 想要了解更多关于 Kafka 命令的信息，请参考官方文档： https://kafka.apache.org/documentation/

Kafka 命令大全

简介Kafka 是一个分布式流处理平台，提供了高吞吐量、低延迟的消息发布和订阅系统。Kafka 命令行工具是与 Kafka 集群交互的主要方式，用于管理和检查 brokers、topics、partitions 等资源。

常用命令

1. 主题管理- **创建主题:** ```bashkafka-topics.sh --bootstrap-server --create --topic --partitions --replication-factor ```- `--bootstrap-server`: Kafka broker 地址列表- `--topic`: 主题名称- `--partitions`: 分区数量- `--replication-factor`: 副本因子- **列出主题:**```bashkafka-topics.sh --bootstrap-server --list```- **描述主题:**```bashkafka-topics.sh --bootstrap-server --describe --topic ```- 查看主题详细信息，例如分区、副本、leader 等- **删除主题:**```bashkafka-topics.sh --bootstrap-server --delete --topic ```

2. 生产者命令- **发送消息:**```bashkafka-console-producer.sh --bootstrap-server --topic ```- 启动控制台生产者，输入消息并发送到指定主题- **指定key发送消息:**```bashkafka-console-producer.sh --bootstrap-server --topic --property parse.key=true --property key.separator=":"```- 启动控制台生产者，并设置`parse.key=true`和分隔符发送key-value消息，例如`key:value`

3. 消费者命令- **消费消息:**```bashkafka-console-consumer.sh --bootstrap-server --topic ```- 启动控制台消费者，从指定主题消费消息- **从指定偏移量消费:**```bashkafka-console-consumer.sh --bootstrap-server --topic --offset ```- `--offset`: 指定消费起始偏移量- **消费指定时间段的消息:**```bashkafka-console-consumer.sh --bootstrap-server --topic --from-beginning --property print.timestamp=true --max-messages ```- `--from-beginning`: 从头开始消费- `--property print.timestamp=true`: 打印消息时间戳- `--max-messages`: 指定消费消息数量

4. 其他常用命令- **查看消费者组:**```bashkafka-consumer-groups.sh --bootstrap-server --list```- **描述消费者组:**```bashkafka-consumer-groups.sh --bootstrap-server --describe --group ```- `--group`: 消费者组ID- **删除消费者组:**```bashkafka-consumer-groups.sh --bootstrap-server --delete --group ```- **查看集群信息:**```bashkafka-topics.sh --describe --zookeeper ```

高级命令除了以上常用命令，Kafka 还提供了一些高级命令，用于更精细化的管理和操作，例如：* `kafka-configs.sh`：管理 Kafka broker 配置 * `kafka-reassign-partitions.sh`: 重新分配分区 * `kafka-preferred-replica-election.sh`: 手动触发 Preferred Leader 选举

总结本文介绍了 Kafka 常用命令，涵盖了主题管理、生产者、消费者和一些其他常用操作。熟练掌握这些命令可以帮助你更好地管理和使用 Kafka 集群。 想要了解更多关于 Kafka 命令的信息，请参考官方文档： https://kafka.apache.org/documentation/