Moving java files to src/main/java

BrianBrechbuhl · Aug 1, 2011 · be7bc44 · be7bc44
1 parent 709afe4
commit be7bc44
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 3 deletions.
diff --git a/...a/javaapi/consumer/ConsumerConnector.java → ...a/javaapi/consumer/ConsumerConnector.java b/...a/javaapi/consumer/ConsumerConnector.java → ...a/javaapi/consumer/ConsumerConnector.java
diff --git a/...vaapi/producer/async/CallbackHandler.java → ...vaapi/producer/async/CallbackHandler.java b/...vaapi/producer/async/CallbackHandler.java → ...vaapi/producer/async/CallbackHandler.java
diff --git a/.../javaapi/producer/async/EventHandler.java → .../javaapi/producer/async/EventHandler.java b/.../javaapi/producer/async/EventHandler.java → .../javaapi/producer/async/EventHandler.java
diff --git a/core/src/main/scala/kafka/tools/ReplayLogProducer.scala b/core/src/main/scala/kafka/tools/ReplayLogProducer.scala
@@ -16,7 +16,7 @@ import kafka.message.{CompressionCodec, Message, MessageSet, FileMessageSet}
 
 object ReplayLogProducer {
 
-  private val GROUPID: String = "replay-log-producer"
+  private val GroupId: String = "replay-log-producer"
   private val logger = Logger.getLogger(getClass)
 
   def main(args: Array[String]) {
@@ -28,12 +28,12 @@ object ReplayLogProducer {
     val allDone = new CountDownLatch(config.numThreads)
 
     // if there is no group specified then avoid polluting zookeeper with persistent group data, this is a hack
-    tryCleanupZookeeper(config.zkConnect, GROUPID)
+    tryCleanupZookeeper(config.zkConnect, GroupId)
     Thread.sleep(500)
 
     // consumer properties
     val consumerProps = new Properties
-    consumerProps.put("groupid", GROUPID)
+    consumerProps.put("groupid", GroupId)
     consumerProps.put("zk.connect", config.zkConnect)
     consumerProps.put("consumer.timeout.ms", "10000")
     consumerProps.put("autooffset.reset", OffsetRequest.SmallestTimeString)