kafka生产者命令（kafka 生产者命令）

Kafka 生产者命令

简介

Apache Kafka 生产者命令是一个用于从本地文件或标准输入向 Kafka 集群发送数据的实用程序。它提供了各种配置选项来控制消息的发送行为。

多级标题

配置选项

-b/--broker-list

：Comma 分隔的 Kafka 代理列表

-t/--topic

：目标 Kafka 主题

-p/--partition

：要发送到的分区（-1 表示随机分区）

-m/--message

：要发送的消息（如果未指定，从标准输入读取）

-f/--file

：包含要发送的消息的文件

-l/--lines

：要发送的行数（-1 表示无限）

-d/--delay

：发送消息之间的延迟（毫秒）

-batch-size

：批量发送消息的大小

-compression-type

：消息压缩类型（none、gzip、snappy、lz4）

-timeout

：发送超时（毫秒）

-retries

：发送故障时的重试次数

内容详细说明

发送单条消息

``` kafka-console-producer --topic my-topic --message "Hello Kafka!" ```

发送多行消息

``` kafka-console-producer --topic my-topic --lines 100 ```

从文件发送消息

``` kafka-console-producer --topic my-topic --file my-file.txt ```

批量发送消息

``` kafka-console-producer --topic my-topic --batch-size 1000 ```

配置消息压缩

``` kafka-console-producer --topic my-topic --compression-type gzip ```

设置发送超时

``` kafka-console-producer --topic my-topic --timeout 5000 ```

重试发送故障

``` kafka-console-producer --topic my-topic --retries 3 ```

其他选项

-dry-run

：执行模拟发送，而不实际发送数据

-help

：显示帮助信息

**Kafka 生产者命令****简介**Apache Kafka 生产者命令是一个用于从本地文件或标准输入向 Kafka 集群发送数据的实用程序。它提供了各种配置选项来控制消息的发送行为。**多级标题****配置选项*** **-b/--broker-list**：Comma 分隔的 Kafka 代理列表 * **-t/--topic**：目标 Kafka 主题 * **-p/--partition**：要发送到的分区（-1 表示随机分区） * **-m/--message**：要发送的消息（如果未指定，从标准输入读取） * **-f/--file**：包含要发送的消息的文件 * **-l/--lines**：要发送的行数（-1 表示无限） * **-d/--delay**：发送消息之间的延迟（毫秒） * **-batch-size**：批量发送消息的大小 * **-compression-type**：消息压缩类型（none、gzip、snappy、lz4） * **-timeout**：发送超时（毫秒） * **-retries**：发送故障时的重试次数**内容详细说明****发送单条消息**``` kafka-console-producer --topic my-topic --message "Hello Kafka!" ```**发送多行消息**``` kafka-console-producer --topic my-topic --lines 100 ```**从文件发送消息**``` kafka-console-producer --topic my-topic --file my-file.txt ```**批量发送消息**``` kafka-console-producer --topic my-topic --batch-size 1000 ```**配置消息压缩**``` kafka-console-producer --topic my-topic --compression-type gzip ```**设置发送超时**``` kafka-console-producer --topic my-topic --timeout 5000 ```**重试发送故障**``` kafka-console-producer --topic my-topic --retries 3 ```**其他选项*** **-dry-run**：执行模拟发送，而不实际发送数据 * **-help**：显示帮助信息