说明
--batch-size
单个批处理中，不同步发送的信息数量
--broker-list
必需：服务器列表
--compression-codec [String: compression-codec]
压缩编码['none', 'gzip', 'snappy', 'lz4', or 'zstd'],默认： gzip
--help Print usage information.
帮助
--line-reader
标准输入中读取行的处理类，默认：kafka.tools.ConsoleProducer$LineMessageReader
--max-block-ms
发送请求期间，最大的阻塞时间,默认： 60000
--max-memory-bytes
在等待发送给服务器数据时，总计最大使用内存，默认：33554432
--max-partition-memory-bytes
分区的最大内存，当接收到的记录小于这个大小时，生产者将尝试将它们乐观地组合在一起，直到达到这个大小为止。默认：16384
--message-send-max-retries
发送信息最大重试次数，默认：3
--metadata-expiry-ms
强制刷新元数据，即使没有任何Leadership改变，单位：毫秒，默认：300000
--producer-property
生产者内置属性，key=value 形式
--producer.config
生产者配置文件，会被[producer-property]覆盖
--property
自己自定义配置 key=value形式
--request-required-acks
请求需要的Acks，默认：1
--request-timeout-ms
ack 请求超时，大于 零的 正数，单位: 毫秒, 默认: 1500
--retry-backoff-ms
在每次重试之前，生产者都会刷新元数据。由于leader选举需要花费时间，此配置指定生产者等待刷新元数据的等待时间。默认：100
--socket-buffer-size
tcp RECV 的大小，默认： 102400
--sync
如果发送消息的请求是同步的，则在前一个返回时，再发送另一个
--timeout
如果配置此值，且生产者为异步运行模式，这将为消息排队等待足够的批大小提供最大时间量。该值用ms表示。默认：1000
--topic
必需：消息必送到的主题名
常用例子：
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Rojer