Kafka系列2:深入理解Kafka生产者( 十 )

linger.ms

该参数制定了生产者在发送批次之前等待更多消息加入批次的时间 。 KafkaProducer会在批次填满或linger.ms达到上限时把批次发送出去 。

client.id

客户端 id , 服务器用来识别消息的来源 。

max.in.flight.requests.per.connection

指定了生产者在收到服务器响应之前可以发送多少个消息 。 它的值越高 , 就会占用越多的内存 , 不过也会提升吞吐量 , 把它设置为 1 可以保证消息是按照发送的顺序写入服务器 , 即使发生了重试 。

timeout.ms、request.timeout.ms和metadata.fetch.timeout.ms