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

(Updated May 15, 2015, 11:14 p.m.)


Review request for kafka.


Bugs: KAFKA-2147
    https://issues.apache.org/jira/browse/KAFKA-2147


Repository: kafka


Description (updated)
-------

add instrumentation


return from pollExpired() on expired items


Diffs (updated)
-----

  core/src/main/scala/kafka/server/FetchRequestPurgatory.scala 
ed1318891253556cdf4d908033b704495acd5724 
  core/src/main/scala/kafka/server/ProducerRequestPurgatory.scala 
e7ff411b6dd98732cb2b33f6d8b65d96bbac688e 
  core/src/main/scala/kafka/server/RequestPurgatory.scala 
87ee3bec9c57d7322f1b5d8caa74b1c8415bcf49 

Diff: https://reviews.apache.org/r/34125/diff/


Testing
-------


Thanks,

Jun Rao

Reply via email to