Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Logger.debug("Getting Child Data")
- var parsedChildren = Map.empty[String, Seq[Long]]
- getStormChildren(zkClient).map[Unit]({ childDatas =>
- Logger.debug("Child Data Got")
- childDatas map { childData: ZNode.Data =>
- val data = new String(childData.bytes)
- Logger.debug("Parsing")
- JSON.parseFull(data) match {
- case Some(map: Map[String, Any]) =>
- Logger.debug("Parsed")
- // Grab all the values we need to identify the nodes
- val name = childData.path.split("/")(1)
- Logger.debug(s"Name: $name")
- val topic = map("topic").toString
- Logger.debug(s"Topic: $topic")
- val partition = map("partition").toString.toInt
- Logger.debug(s"Partition: $partition")
- val offset = map("offset").toString.toLong
- Logger.debug(s"Offset: $offset")
- Logger.debug("Values properly pulled")
- val baseSeq: Seq[Long] = Seq.fill(numPartitions)(0)
- [info] Set current project to kafka-web-console (in build file:/home/ubuntu/app/kafka-web-console/)
- (Starting server. Type Ctrl+D to exit logs, the server will remain in background)
- Play server process ID is 28417
- [info] play - database [default] connected at jdbc:h2:file:play
- [info] play - Starting application default Akka system.
- [info] play - Application started (Prod)
- [info] play - Listening for HTTP on /0:0:0:0:0:0:0:0:9000
- log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).
- log4j:WARN Please initialize the log4j system properly.
- [debug] application - Getting partition leaders for topic meter_data_production
- [debug] application - Getting partition log sizes for topic meter_data_production from partition leaders 10.160.9.103:9092, 10.160.9.23:9092
- [debug] application - Getting partition owners for topic meter_data_production
- [debug] application - Getting partition offsets for topic meter_data_production
- [debug] application - Getting Kafka partition offsets
- [debug] application - Getting Child Data
- [debug] application - Child Data Got
- [debug] application - Parsing
- [debug] application - Parsed
- [debug] application - Name: ratt-usage-topology-qa
- [debug] application - Topic: alerting_cleangrain_qa
- [info] play - Shutdown application default Akka system.
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement