kafka消费者命令参数及其作用
使用 /www/server/kafka/bin/kafka-console-producer.sh 时, 可用参数列表:
| 参数 | 作用 |
|---|---|
| --batch-size <Integer: size> | 如果不是同步发送，则在单个批处理中发送的邮件数。请注意，如果最大分区内存字节也设置为默认值：16384，则此选项将被替换） |
| --bootstrap-server <String: server to connect to> | 必需，除非指定了--broker列表（已弃用）。要连接到的服务器。形式为HOST1:PORT1、HOST2:PORT2的broker列表字符串。 |
| --broker-list <String: broker-list> | 已弃用，请改用--bootstrap-server；如果指定了--bootstrap-server，则忽略。形式为HOST1:PORT1、HOST2:PORT2的broker列表字符串。 |
| --compression-codec [String:compression-codec] | 压缩编解码器：“none”、“gzip”、“snappy”、“lz4”或“zstd”。如果未指定值，则默认为“gzip” |
| --help | 打印帮助信息. |
| --line-reader <String: reader_class> | 用于从中的标准读取行的类的类名。默认情况下，每行都作为单独的消息读取。（默认值：kafka.tools.ConsoleProducer$LineMessageReader） |
| --max-block-ms <Long: max block on send> | 生产者在发送请求期间阻止的最长时间。（默认值：60000） |
| --max-memory-bytes <Long: total memory in bytes> | 生产者用于缓冲等待发送到服务器的记录的总内存。这是在生产者配置中控制“buffer.memory”的选项。（默认值：33554432） |
| --max-partition-memory-bytes <Integer: memory in bytes per partition> | 为分区分配的缓冲区大小。当收到小于此大小的记录时，生产者将尝试乐观地将它们组合在一起，直到达到此大小。这是在生产者配置中控制“batch.size”的选项。（默认值：16384） |
| --message-send-max-retries |
代理可能由于多种原因无法接收消息，而暂时不可用只是其中之一。此属性指定生产者放弃并丢弃此消息之前的重试次数。这是在生产者配置中控制“重试次数”的选项。（默认值：3） |
| --metadata-expiry-ms <Long: metadata expiration interval> | 以毫秒为单位的时间段，在此之后，即使我们没有看到任何领导层变动，我们也会强制刷新元数据。这是在生产者配置中控制“metadata.max.age.ms”的选项。（默认：300000） |
| --producer-property <String: producer_prop> | 将key=value形式的用户定义属性传递给生产者的机制。 |
| --producer.config <String: config file> | 生产者配置属性文件。请注意，[producer-property]优先于此配置。 |
| --property <String: prop> | 将key=value形式的用户定义属性传递给消息读取器的机制。这允许为用户定义的消息读取器进行自定义配置。默认属性包括：parse.key=false parse.headers=false ignore。error=false key。分隔符=\t标头。分隔符=\t标头，headers.key.separtment=：null.marker=设置时，当parse.headers=true和parse.key=true:“h1:v1，h2:v2…\tkey\tvalue”parse.key=true:parse.headers=true:“h1:v1，h2:v2…\tvalue” |
| --reader-config <String: config file> | a 配置消息读取器的属性文件。请注意，[property]优先于此配置。 |
| --request-required-acks <String: request required acks> | 生产者请求所需的“acks”（默认值：-1） |
| --request-timeout-ms <Integer: request timeout ms> | 生产者请求的ack超时。值必须为非负且非零。（默认值：1500） |
| --retry-backoff-ms |
每次重试之前，生产者都会刷新相关主题的元数据。由于leader选举需要一些时间，因此此属性指定生产者在刷新元数据之前等待的时间。这是在生产者配置中控制“retry.backoff.ms”的选项。（默认值：100） |
| --socket-buffer-size <Integer: size> | tcp RECV大小的大小。这是在生产者配置中控制“send.buffer.bytes”的选项。（默认值：102400） |
| --sync | 如果设置消息发送请求到代理是同步的，则在它们到达时一次一个。 |
| --timeout <Long: timeout_ms> | 如果设置了，并且生产者以异步模式运行，这将为消息排队等待足够的批处理大小提供最大时间。该值以毫秒为单位。这是在生产者配置中控制“linger.ms”的选项。（默认值：1000） |
| --topic <String: topic> | 必须:要向其生成消息的主题id |
| --version | 显示 Kafka 版本. |
本文为Larwas原创文章,转载无需和我联系,但请注明来自larwas博客 https://larwas.com
- 上一篇： kafka消费者命令参数及其作用
- 下一篇： php-rdkafka中全局配置属性表(翻译备用)
请先登录后发表评论
- latest comments
- 总共0条评论
最新评论