Add api route to fetch topics

app/controllers/api/Topic.scala

@@ -0,0 +1,28 @@
+/**
+ * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0
+ * See accompanying LICENSE file.
+ */
+
+package controllers.api
+
+import controllers.KafkaManagerContext
+import controllers.Topic._
+import play.api.libs.json._
+import play.api.mvc._
+
+object Topic extends Controller {
+
+  import play.api.libs.concurrent.Execution.Implicits.defaultContext
+
+  private[this] val kafkaManager = KafkaManagerContext.getKafkaManager
+
+  def index(c: String) = Action.async { implicit request =>
+    kafkaManager.getTopicListExtended(c).map { errorOrTopicList =>
+      errorOrTopicList.fold(
+        error => BadRequest(Json.obj("msg" -> error.msg)),
+        topicList => Ok(Json.obj("topicList" -> topicList.list.map(bi => bi._1)))
+      )
+    }
+  }
+}
+

app/views/logkafka/logkafkaList.scala.html

@@ -15,7 +15,9 @@
 @logkafkaScripts = {
     <script ype="text/javascript">
     $(document).ready(function() {
-        $('#logkafkas-table').DataTable();
+        $('#logkafkas-table').DataTable({
+           "iDisplayLength": 100
+        });
     } );
     </script>
 }

conf/routes

@@ -54,6 +54,7 @@ POST        /clusters/:c/logkafkas/:h/:l/enableConfig     controllers.Logkafka.h
 GET         /api/status/:c/availableBrokers               controllers.api.KafkaHealthCheck.availableBrokers(c:String)
 GET         /api/status/:c/:t/underReplicatedPartitions   controllers.api.KafkaHealthCheck.underReplicatedPartitions(c:String,t:String)
 GET         /api/status/:c/:t/unavailablePartitions       controllers.api.KafkaHealthCheck.unavailablePartitions(c:String,t:String)
+GET         /api/:c/topics                                controllers.api.Topic.index(c:String)
 
 # Versioned Assets
 GET         /vassets/*file          controllers.Assets.versioned(path="/public", file: Asset)