root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

KAFKA-439 Fix bad javadoc. Patch from Jim Plush. Reviewed and modified by Jay Kreps. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373052 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Edward Jay Kreps 2012-08-14 19:47:54 +00:00
parent ee855fe1aa
commit a8790784df
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/scala/kafka/server/ReplicaManager.scala
View File

@ -315,7 +315,7 @@ class ReplicaManager(val config: KafkaConfig, time: Time, val zkClient: ZkClient
/** /**
* Reads the checkpointed highWatermarks for all partitions * 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) def readCheckpointedHighWatermark(topic: String, partition: Int): Long = highwaterMarkCheckpoint.read(topic, partition)

6
core/src/main/scala/kafka/utils/Utils.scala
View File

@ -502,7 +502,7 @@ object Utils extends Logging {
* instead it just returns false indicating the registration failed. * instead it just returns false indicating the registration failed.
* @param mbean The object to register as an mbean * @param mbean The object to register as an mbean
* @param name The name to register this mbean with * @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 = { def registerMBean(mbean: Object, name: String): Boolean = {
try { 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 * Compute the CRC32 of the segment of the byte array given by the specificed size and offset
* @param bytes The bytes to checksum * @param bytes The bytes to checksum
* @param the offset at which to begin checksumming * @param offset the offset at which to begin checksumming
* @param the number of bytes to checksum * @param size the number of bytes to checksum
* @return The CRC32 * @return The CRC32
*/ */
def crc32(bytes: Array[Byte], offset: Int, size: Int): Long = { def crc32(bytes: Array[Byte], offset: Int, size: Int): Long = {