diff --git a/core/src/main/scala/kafka/log/LogManager.scala b/core/src/main/scala/kafka/log/LogManager.scala
index a3cac7e..3ea950f 100644
--- a/core/src/main/scala/kafka/log/LogManager.scala
+++ b/core/src/main/scala/kafka/log/LogManager.scala
@@ -124,7 +124,7 @@ class LogManager(val logDirs: Array[File],
         val dirLogs = logsByDir.getOrElse(dir.toString, Map()).values
 
         val dirJobs = dirLogs map { log =>
-          Utils.runnable { () => {
+          Utils.runnable {
             debug("Loading log '" + dir.getName + "'")
 
             val topicPartition = Log.parseTopicPartitionName(dir.getName)
@@ -139,7 +139,7 @@ class LogManager(val logDirs: Array[File],
                 "Duplicate log directories found: %s, %s!".format(
                 log.dir.getAbsolutePath, previous.dir.getAbsolutePath))
             }
-          }}
+          }
         }
 
         jobs(cleanShutdownFile) = dirJobs.map(pool.submit).toSeq
@@ -213,7 +213,7 @@ class LogManager(val logDirs: Array[File],
       val dirLogs = logsByDir.getOrElse(dir.toString, Map()).values
 
       val dirJobs = dirLogs map { log =>
-        Utils.runnable { () =>
+        Utils.runnable {
           // flush the log to ensure latest possible recovery point
           log.flush()
           log.close()
diff --git a/core/src/main/scala/kafka/utils/KafkaScheduler.scala b/core/src/main/scala/kafka/utils/KafkaScheduler.scala
index 8e37505..9a16343 100644
--- a/core/src/main/scala/kafka/utils/KafkaScheduler.scala
+++ b/core/src/main/scala/kafka/utils/KafkaScheduler.scala
@@ -93,16 +93,14 @@ class KafkaScheduler(val threads: Int,
     debug("Scheduling task %s with initial delay %d ms and period %d ms."
         .format(name, TimeUnit.MILLISECONDS.convert(delay, unit), TimeUnit.MILLISECONDS.convert(period, unit)))
     ensureStarted
-    val runnable = new Runnable {
-      def run() = {
-        try {
-          trace("Begining execution of scheduled task '%s'.".format(name))
-          fun()
-        } catch {
-          case t: Throwable => error("Uncaught exception in scheduled task '" + name +"'", t)
-        } finally {
-          trace("Completed execution of scheduled task '%s'.".format(name))
-        }
+    val runnable = Utils.runnable {
+      try {
+        trace("Begining execution of scheduled task '%s'.".format(name))
+        fun()
+      } catch {
+        case t: Throwable => error("Uncaught exception in scheduled task '" + name +"'", t)
+      } finally {
+        trace("Completed execution of scheduled task '%s'.".format(name))
       }
     }
     if(period >= 0)
diff --git a/core/src/main/scala/kafka/utils/Utils.scala b/core/src/main/scala/kafka/utils/Utils.scala
index 63d3dda..c20f45e 100644
--- a/core/src/main/scala/kafka/utils/Utils.scala
+++ b/core/src/main/scala/kafka/utils/Utils.scala
@@ -49,9 +49,9 @@ object Utils extends Logging {
    * @param fun A function
    * @return A Runnable that just executes the function
    */
-  def runnable(fun: () => Unit): Runnable = 
-    new Runnable() {
-      def run() = fun()
+  def runnable(fun: => Unit): Runnable =
+    new Runnable {
+      def run() = fun
     }
 
   /**