> On Dec. 10, 2013, 4:14 p.m., Jun Rao wrote:
> > It seems that in the consumer, we have a separate request timeout and 
> > socket timeout. The producer only has a request timeout now. Perhaps we 
> > should add the socket timeout in the producer too?

Currently request.timeout.ms of producer config is used as both socket timeout 
for the channel and produce ack timeout. Are you suggesting decoupling them by 
adding another socket timeout parameter?


- Guozhang


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/16092/#review30101
-----------------------------------------------------------


On Dec. 9, 2013, 5:14 p.m., Guozhang Wang wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/16092/
> -----------------------------------------------------------
> 
> (Updated Dec. 9, 2013, 5:14 p.m.)
> 
> 
> Review request for kafka.
> 
> 
> Bugs: KAFKA-1147
>     https://issues.apache.org/jira/browse/KAFKA-1147
> 
> 
> Repository: kafka
> 
> 
> Description
> -------
> 
> KAFKA-1147.v2.1
> 
> 
> KAFKA-1147.v2
> 
> 
> Diffs
> -----
> 
>   core/src/main/scala/kafka/consumer/ConsumerConfig.scala 
> c8c4212f62dd52158e6504cba87b300e6830e5fe 
>   core/src/main/scala/kafka/server/KafkaConfig.scala 
> a7e5b739454aec796070d95b003f20f79c84ef89 
> 
> Diff: https://reviews.apache.org/r/16092/diff/
> 
> 
> Testing
> -------
> 
> 
> Thanks,
> 
> Guozhang Wang
> 
>

Reply via email to