git commit: KAFKA-889 Add mbeans to track socket server's response queue size in addition to request queue size; reviewed by Jun Rao and Joel Koshy

[nehanarkhede]

Updated Branches:
  refs/heads/0.8 d726e14ee - cae19aa44


KAFKA-889 Add mbeans to track socket server's response queue size in addition 
to request queue size; reviewed by Jun Rao and Joel Koshy


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cae19aa4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/cae19aa4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/cae19aa4

Branch: refs/heads/0.8
Commit: cae19aa44f36775d8f95256e63e0cb50a0c0ba9f
Parents: d726e14
Author: Neha Narkhede neha.narkh...@gmail.com
Authored: Tue Apr 30 15:35:01 2013 -0700
Committer: Neha Narkhede neha.narkh...@gmail.com
Committed: Tue Apr 30 15:35:01 2013 -0700

--
 .../main/scala/kafka/network/RequestChannel.scala  |9 +
 1 files changed, 9 insertions(+), 0 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/kafka/blob/cae19aa4/core/src/main/scala/kafka/network/RequestChannel.scala
--
diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala 
b/core/src/main/scala/kafka/network/RequestChannel.scala
index c0e0dfc..c8f81c0 100644
--- a/core/src/main/scala/kafka/network/RequestChannel.scala
+++ b/core/src/main/scala/kafka/network/RequestChannel.scala
@@ -103,6 +103,15 @@ class RequestChannel(val numProcessors: Int, val 
queueSize: Int) extends KafkaMe
 }
   )
 
+  for(i - 0 until numProcessors) {
+newGauge(
+  Processor- + i + -ResponseQueueSize,
+  new Gauge[Int] {
+def value = responseQueues(i).size()
+  }
+)
+  }
+
   /** Send a request to be handled, potentially blocking until there is room 
in the queue for the request */
   def sendRequest(request: RequestChannel.Request) {
 requestQueue.put(request)

svn commit: r1477910 - /kafka/site/08/tools.html

[junrao]

Author: junrao
Date: Wed May  1 04:24:33 2013
New Revision: 1477910

URL: http://svn.apache.org/r1477910
Log:
add a link to 0.8 adminstrative tools

Modified:
kafka/site/08/tools.html

Modified: kafka/site/08/tools.html
URL: 
http://svn.apache.org/viewvc/kafka/site/08/tools.html?rev=1477910r1=1477909r2=1477910view=diff
==
--- kafka/site/08/tools.html (original)
+++ kafka/site/08/tools.html Wed May  1 04:24:33 2013
@@ -3,5 +3,8 @@
 h3 Migrating data from 0.7 to 0.8/h3
 Since 0.8 is not backward compatible with 0.7.x, we provide a tool for 
migrating data in an 0.7 cluster to an 0.8 cluster. Details of the tool can be 
found a 
href=https://cwiki.apache.org/confluence/display/KAFKA/Migrating+from+0.7+to+0.8;here/a.
 
+h3 Administrative tools for 0.8/h3
+A set of tools for managing an 0.8 cluster is described in a 
href=https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools;here/a.
+
 !--#include virtual=includes/footer.html --