| –batch-size <Integer: size> | 单个批处理中发送的消息数(default: 200) |
| –bootstrap-server | |
| –broker-list <String: broker-list> | 废弃。 |
| –compression-codec [String:compression-codec] | 压缩编解码器: either ‘none’, ‘gzip’, ‘snappy’, ‘lz4’, or ‘zstd’. 默认值：gzip |
| –line-reader <String: reader_class> | 从标准输入读取信息的class类名称。 (default: kafka.tools.ConsoleProducer$LineMessageReader) |
| –max-block-ms <Long: ms> | 在发送请求期间，生产者将阻止的最长时间。(default: 60000) |
| –max-memory-bytes <Long: bytes> | 内存(default: 33554432，23M) |
| –max-partition-memory-bytes <Long: bytes> | 为分区分配的缓冲区大小(default: 16384，16K) |
| –message-send-max-retries | 最大的重试发送次数(default: 3) |
| –metadata-expiry-ms <Long: > | 强制更新元数据的时间阈值(ms)(default: 300000) |
| –producer-property <String:producer_prop> | 将自定义属性传递给生成器的机制。形如：key=value |
| –producer.config <String: config file> | 生产者配置属性文件。[–producer-property]优先于此配置 |
| –property <String: prop> | 自定义消息读取器。 |
| –request-required-acks String: | 生产者请求的确认方式。0、1(默认值)、all |
| –request-timeout-ms <Integer: ms> | 生产者请求的确认超时时间 默认值：1500 |
| –retry-backoff-ms | 生产者重试前，刷新元数据的等待时间阈值(default: 100) |
| –socket-buffer-size <Integer: size> | TCP接收缓冲大小. (default: 102400) |
| –sync | 同步发送消息 |
| –timeout <Integer: timeout_ms> | 异步发送模式，超时时间。默认值：1000 |
| –topic | |
| –version | |
