KAFKA-1755; trivial follow-up to fix comment in CleanerTest

oscerd · Mar 4, 2015 · 00c643e · 00c643e
1 parent 151ae42
commit 00c643e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/test/scala/unit/kafka/log/CleanerTest.scala b/core/src/test/scala/unit/kafka/log/CleanerTest.scala
@@ -98,14 +98,14 @@ class CleanerTest extends JUnitSuite {
     // create a log with compaction turned off so we can append unkeyed messages
     val log = makeLog(config = logConfig.copy(segmentSize = 1024, compact = false))
 
-    // append messages with unkeyed messages
+    // append unkeyed messages
     while(log.numberOfSegments < 2)
       log.append(unkeyedMessage(log.logEndOffset.toInt))
     val numInvalidMessages = unkeyedMessageCountInLog(log)
 
     val sizeWithUnkeyedMessages = log.size
 
-    // append messages with unkeyed messages
+    // append keyed messages
     while(log.numberOfSegments < 3)
       log.append(message(log.logEndOffset.toInt, log.logEndOffset.toInt))