svn commit: r1373052 - in /incubator/kafka/branches/0.8/core/src/main/scala/kafka: server/ReplicaManager.scala utils/Utils.scala

[jk...@apache.org]

Author: jkreps
Date: Tue Aug 14 19:47:54 2012
New Revision: 1373052

URL: http://svn.apache.org/viewvc?rev=1373052&view=rev
Log:
KAFKA-439 Fix bad javadoc. Patch from Jim Plush. Reviewed and modified by Jay Kreps.


Modified:
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala?rev=1373052&r1=1373051&r2=1373052&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala (original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala Tue Aug 14 19:47:54 2012
@@ -315,7 +315,7 @@ class ReplicaManager(val config: KafkaCo
 
   /**
    * Reads the checkpointed highWatermarks for all partitions
-   * @returns checkpointed value of highwatermark for topic, partition. If one doesn't exist, returns 0
+   * @return checkpointed value of highwatermark for topic, partition. If one doesn't exist, returns 0
    */
   def readCheckpointedHighWatermark(topic: String, partition: Int): Long = highwaterMarkCheckpoint.read(topic, partition)
 

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala?rev=1373052&r1=1373051&r2=1373052&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala (original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala Tue Aug 14 19:47:54 2012
@@ -502,7 +502,7 @@ object Utils extends Logging {
    * instead it just returns false indicating the registration failed.
    * @param mbean The object to register as an mbean
    * @param name The name to register this mbean with
-   * @returns true if the registration succeeded
+   * @return true if the registration succeeded
    */
   def registerMBean(mbean: Object, name: String): Boolean = {
     try {
@@ -581,8 +581,8 @@ object Utils extends Logging {
   /**
    * Compute the CRC32 of the segment of the byte array given by the specificed size and offset
    * @param bytes The bytes to checksum
-   * @param the offset at which to begin checksumming
-   * @param the number of bytes to checksum
+   * @param offset the offset at which to begin checksumming
+   * @param size the number of bytes to checksum
    * @return The CRC32
    */
   def crc32(bytes: Array[Byte], offset: Int, size: Int): Long = {