String:producer_prop
自定义的属性(key=value)传递给生产者的机制。
–producer.config <String: config file>
生产者配置属性文件。注意,[producer-property]优先级更高
–property <String: prop>
A mechanism to pass user-defined properties in the form key=value to the message reader. This allows custom configuration for a user- defined message reader.
–queue-enqueuetimeout-ms <Integer:queue enqueuetimeout ms>
队列事件超时时间 (default: 2147483647)
–queue-size <Integer: queue_size>
生产者在异步模式下运行提供最大数量的消息将排队等待足够的批大小。(default: 10000)
–request-required-acks <String: request required acks>
生产者请求所需的ack(default: 1)
–request-timeout-ms <Integer: request timeout ms>
ack请求超时时间 (default: 1500)
–retry-backoff-ms
在每次重试之前,生产者刷新相关主题的元数据。由于leader election要花费一些时间,因此此属性指定生产者在刷新元数据之前等待的时间量。(default: 100)
–socket-buffer-size <Integer: size>
The size of the tcp RECV size. (default: 102400)
–sync
如果设置发送消息是同步的,一个批次的消息会同时到达。
–timeout <Integer: timeout_ms>
如果设置和生产者是在异步模式下运行,这将为消息队列等待足够的批处理大小提供最大时间量。数值用ms表示。(default: 1000)
–key-serializer String:encoder_class
key 序列化方式
–value-serializer <String: encoder_class>
value 序列化方式
Integer:interval_ms
打印进度信息的间隔 单位毫秒。 (default: 5000)
–show-detailed-stats
每隔指定的时间返回一次状态
–socket-buffer-size <Integer: size>
The size of the tcp RECV size. (default: 2097152)
–threads <Integer: count>
线程数 (default: 10)
–help
打印帮助信息
[root@node2 bin]
start.time, end.time, data.consumed.in.MB, MB.sec, data.consumed.in.nMsg, nMsg.sec, rebalance.time.ms, fetch.time.ms, fetch.MB.sec, fetch.nMsg.sec
2020-02-19 23:45:14:743, 2020-02-19 23:45:15:027, 0.0010, 0.0034, 1000, 3521.1268, 24, 260, 0.0037, 3846.1538
性能测试扩展阅读:https://www.cnblogs.com/xiaodf/p/6023531.html