kafkaOffsetMonitor breaking changes

KafkaOffsetMonitor git:(master) sbt assembly
[info] Loading project definition from /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/project
[warn] Multiple resolvers having different access mechanism configured with same name 'sbt-plugin-releases'. To avoid conflict, Remove duplicate project resolvers (`resolvers`) or rename publishing resolver (`publishTo`).
[info] Compiling 1 Scala source to /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/project/target/scala-2.10/sbt-0.13/classes...
[info] Set current project to KafkaOffsetMonitor (in build file:/Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/)
[info] Updating {file:/Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/}offsetmonitor...
[info] Resolving org.fusesource.jansi#jansi;1.4 ...
[info] Done updating.
[info] Compiling 6 Scala sources to /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/target/scala-2.10/classes...
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/kafka/OffsetGetter.scala:43: value readDataMaybeNull is not a member of object kafka.utils.ZkUtils
[error]       ZkUtils.readDataMaybeNull(zkClient, ZkUtils.BrokerIdsPath + "/" + bid) match {
[error]               ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/kafka/OffsetGetter.scala:45: type mismatch;
[error]  found   : Any
[error]  required: String
[error]           Json.parseFull(brokerInfoString) match {
[error]                          ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/kafka/OffsetGetter.scala:65: value getPartitionsForTopics is not a member of object kafka.utils.ZkUtils
[error]     val pidMap = ZkUtils.getPartitionsForTopics(zkClient, Seq(topic))
[error]                          ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/kafka/OffsetGetter.scala:106: value getChildren is not a member of object kafka.utils.ZkUtils
[error]       ZkUtils.getChildren(zkClient, ZkUtils.BrokerTopicsPath).sortWith(_ < _)
[error]               ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/kafka/OffsetGetter.scala:116: value getAllBrokersInCluster is not a member of object kafka.utils.ZkUtils
[error]     val clusterNodes = ZkUtils.getAllBrokersInCluster(zkClient).map((broker) => {
[error]                                ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/kafka/OffsetGetter.scala:215: object ZKStringSerializer in package utils cannot be accessed in package kafka.utils
[error]       ZKStringSerializer)
[error]       ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/kafka/core/KafkaOffsetGetter.scala:45: value timestamp is not a member of kafka.common.OffsetAndMetadata
[error]                   creation = Time.fromMilliseconds(offsetMetaData.timestamp),
[error]                                                                   ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:24: value getAllPartitions is not a member of object kafka.utils.ZkUtils
[error]   def getAllPartitions(zkClient: ZkClient): collection.Set[TopicAndPartition] = delegator.getAllPartitions(zkClient)
[error]                                                                                           ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:26: value getAllTopics is not a member of object kafka.utils.ZkUtils
[error]   def getAllTopics(zkClient: ZkClient): Seq[String] = delegator.getAllTopics(zkClient)
[error]                                                                 ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:28: value getBrokerInfo is not a member of object kafka.utils.ZkUtils
[error]   def getBrokerInfo(zkClient: ZkClient, brokerId: Int): Option[Broker] = delegator.getBrokerInfo(zkClient, brokerId)
[error]                                                                                    ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:30: value getConsumersPerTopic is not a member of object kafka.utils.ZkUtils
[error]   def getConsumersPerTopic(zkClient: ZkClient, group: String, excludeInternalTopics: Boolean): mutable.Map[String, List[ConsumerThreadId]] = delegator.getConsumersPerTopic(zkClient, group, excludeInternalTopics)
[error]                                                                                                                                                        ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:32: value getConsumersInGroup is not a member of object kafka.utils.ZkUtils
[error]   def getConsumersInGroup(zkClient: ZkClient, group: String): Seq[String] = delegator.getConsumersInGroup(zkClient, group)
[error]                                                                                       ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:34: value deletePartition is not a member of object kafka.utils.ZkUtils
[error]   def deletePartition(zkClient: ZkClient, brokerId: Int, topic: String): Unit = delegator.deletePartition(zkClient, brokerId, topic)
[error]                                                                                           ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:36: value getPartitionsUndergoingPreferredReplicaElection is not a member of object kafka.utils.ZkUtils
[error]   def getPartitionsUndergoingPreferredReplicaElection(zkClient: ZkClient): collection.Set[TopicAndPartition] = delegator.getPartitionsUndergoingPreferredReplicaElection(zkClient)
[error]                                                                                                                          ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:38: value updatePartitionReassignmentData is not a member of object kafka.utils.ZkUtils
[error]   def updatePartitionReassignmentData(zkClient: ZkClient, partitionsToBeReassigned: collection.Map[TopicAndPartition, Seq[Int]]): Unit = delegator.updatePartitionReassignmentData(zkClient, partitionsToBeReassigned)
[error]                                                                                                                                                    ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:40: value getPartitionReassignmentZkData is not a member of object kafka.utils.ZkUtils
[error]   def getPartitionReassignmentZkData(partitionsToBeReassigned: collection.Map[TopicAndPartition, Seq[Int]]): String = delegator.getPartitionReassignmentZkData(partitionsToBeReassigned)
[error]                                                                                                                                 ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:42: value parseTopicsData is not a member of object kafka.utils.ZkUtils
[error]   def parseTopicsData(jsonData: String): Seq[String] = delegator.parseTopicsData(jsonData)
[error]                                                                  ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:44: value parsePartitionReassignmentData is not a member of object kafka.utils.ZkUtils
[error]   def parsePartitionReassignmentData(jsonData: String): collection.Map[TopicAndPartition, Seq[Int]] = delegator.parsePartitionReassignmentData(jsonData)
[error]                                                                                                                 ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:46: value parsePartitionReassignmentDataWithoutDedup is not a member of object kafka.utils.ZkUtils
[error]   def parsePartitionReassignmentDataWithoutDedup(jsonData: String): Seq[(TopicAndPartition, Seq[Int])] = delegator.parsePartitionReassignmentDataWithoutDedup(jsonData)
[error]                                                                                                                    ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:48: value getPartitionsBeingReassigned is not a member of object kafka.utils.ZkUtils
[error]   def getPartitionsBeingReassigned(zkClient: ZkClient): collection.Map[TopicAndPartition, ReassignedPartitionsContext] = delegator.getPartitionsBeingReassigned(zkClient)
[error]                                                                                                                                    ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:50: value getPartitionsForTopics is not a member of object kafka.utils.ZkUtils
[error]   def getPartitionsForTopics(zkClient: ZkClient, topics: Seq[String]): mutable.Map[String, Seq[Int]] = delegator.getPartitionsForTopics(zkClient, topics)
[error]                                                                                                                  ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:52: value getPartitionAssignmentForTopics is not a member of object kafka.utils.ZkUtils
[error]   def getPartitionAssignmentForTopics(zkClient: ZkClient, topics: Seq[String]): mutable.Map[String, collection.Map[Int, Seq[Int]]] = delegator.getPartitionAssignmentForTopics(zkClient, topics)
[error]                                                                                                                                                ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:54: value getReplicaAssignmentForTopics is not a member of object kafka.utils.ZkUtils
[error]   def getReplicaAssignmentForTopics(zkClient: ZkClient, topics: Seq[String]): mutable.Map[TopicAndPartition, Seq[Int]] = delegator.getReplicaAssignmentForTopics(zkClient, topics)
[error]                                                                                                                                    ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:56: value getPartitionLeaderAndIsrForTopics is not a member of object kafka.utils.ZkUtils
[error]   def getPartitionLeaderAndIsrForTopics(zkClient: ZkClient, topicAndPartitions: collection.Set[TopicAndPartition]): mutable.Map[TopicAndPartition, LeaderIsrAndControllerEpoch] = delegator.getPartitionLeaderAndIsrForTopics(zkClient, topicAndPartitions)
[error]                                                                                                                                                                                             ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:58: value pathExists is not a member of object kafka.utils.ZkUtils
[error]   def pathExists(client: ZkClient, path: String): Boolean = delegator.pathExists(client, path)
[error]                                                                       ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:60: value getChildrenParentMayNotExist is not a member of object kafka.utils.ZkUtils
[error]   def getChildrenParentMayNotExist(client: ZkClient, path: String): Seq[String] = delegator.getChildrenParentMayNotExist(client, path)
[error]                                                                                             ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:62: value getChildren is not a member of object kafka.utils.ZkUtils
[error]   def getChildren(client: ZkClient, path: String): Seq[String] = delegator.getChildren(client, path)
[error]                                                                            ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:64: value readDataMaybeNull is not a member of object kafka.utils.ZkUtils
[error]   def readDataMaybeNull(client: ZkClient, path: String): (Option[String], Stat) = delegator.readDataMaybeNull(client, path)
[error]                                                                                             ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:66: value readData is not a member of object kafka.utils.ZkUtils
[error]   def readData(client: ZkClient, path: String): (String, Stat) = delegator.readData(client, path)
[error]                                                                            ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:70: value deletePathRecursive is not a member of object kafka.utils.ZkUtils
[error]   def deletePathRecursive(client: ZkClient, path: String): Unit = delegator.deletePathRecursive(client, path)
[error]                                                                             ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:72: value deletePath is not a member of object kafka.utils.ZkUtils
[error]   def deletePath(client: ZkClient, path: String): Boolean = delegator.deletePath(client, path)
[error]                                                                       ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:74: value updateEphemeralPath is not a member of object kafka.utils.ZkUtils
[error]   def updateEphemeralPath(client: ZkClient, path: String, data: String): Unit = delegator.updateEphemeralPath(client, path, data)
[error]                                                                                           ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:76: value conditionalUpdatePersistentPathIfExists is not a member of object kafka.utils.ZkUtils
[error]   def conditionalUpdatePersistentPathIfExists(client: ZkClient, path: String, data: String, expectVersion: Int): (Boolean, Int) = delegator.conditionalUpdatePersistentPathIfExists(client, path, data, expectVersion)
[error]                                                                                                                                             ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:78: value conditionalUpdatePersistentPath is not a member of object kafka.utils.ZkUtils
[error]   def conditionalUpdatePersistentPath(client: ZkClient, path: String, data: String, expectVersion: Int, optionalChecker: Option[(ZkClient, String, String) => (Boolean, Int)]): (Boolean, Int) = delegator.conditionalUpdatePersistentPath(client, path, data, expectVersion, optionalChecker)
[error]                                                                                                                                                                                                            ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:80: value updatePersistentPath is not a member of object kafka.utils.ZkUtils
[error]   def updatePersistentPath(client: ZkClient, path: String, data: String): Unit = delegator.updatePersistentPath(client, path, data)
[error]                                                                                            ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:82: value createSequentialPersistentPath is not a member of object kafka.utils.ZkUtils
[error]   def createSequentialPersistentPath(client: ZkClient, path: String, data: String): String = delegator.createSequentialPersistentPath(client, path, data)
[error]                                                                                                        ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:84: value createPersistentPath is not a member of object kafka.utils.ZkUtils
[error]   def createPersistentPath(client: ZkClient, path: String, data: String): Unit = delegator.createPersistentPath(client, path, data)
[error]                                                                                            ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:86: value createEphemeralPathExpectConflictHandleZKBug is not a member of object kafka.utils.ZkUtils
[error]   def createEphemeralPathExpectConflictHandleZKBug(zkClient: ZkClient, path: String, data: String, expectedCallerData: Any, checker: (String, Any) => Boolean, backoffTime: Int): Unit = delegator.createEphemeralPathExpectConflictHandleZKBug(zkClient, path, data, expectedCallerData, checker, backoffTime)
[error]                                                                                                                                                                                                    ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:88: value createEphemeralPathExpectConflict is not a member of object kafka.utils.ZkUtils
[error]   def createEphemeralPathExpectConflict(client: ZkClient, path: String, data: String): Unit = delegator.createEphemeralPathExpectConflict(client, path, data)
[error]                                                                                                         ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:90: value makeSurePersistentPathExists is not a member of object kafka.utils.ZkUtils
[error]   def makeSurePersistentPathExists(client: ZkClient, path: String): Unit = delegator.makeSurePersistentPathExists(client, path)
[error]                                                                                      ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:92: value replicaAssignmentZkData is not a member of object kafka.utils.ZkUtils
[error]   def replicaAssignmentZkData(map: collection.Map[String, Seq[Int]]): String = delegator.replicaAssignmentZkData(map)
[error]                                                                                          ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:94: value leaderAndIsrZkData is not a member of object kafka.utils.ZkUtils
[error]   def leaderAndIsrZkData(leaderAndIsr: LeaderAndIsr, controllerEpoch: Int): String = delegator.leaderAndIsrZkData(leaderAndIsr, controllerEpoch)
[error]                                                                                                ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:96: value getConsumerPartitionOwnerPath is not a member of object kafka.utils.ZkUtils
[error]   def getConsumerPartitionOwnerPath(group: String, topic: String, partition: Int): String = delegator.getConsumerPartitionOwnerPath(group, topic, partition)
[error]                                                                                                       ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:98: value registerBrokerInZk is not a member of object kafka.utils.ZkUtils
[error]   def registerBrokerInZk(zkClient: ZkClient, id: Int, host: String, port: Int, timeout: Int, jmxPort: Int): Unit = delegator.registerBrokerInZk(zkClient, id, host, port, timeout, jmxPort)
[error]                                                                                                                              ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:100: value getReplicasForPartition is not a member of object kafka.utils.ZkUtils
[error]   def getReplicasForPartition(zkClient: ZkClient, topic: String, partition: Int): Seq[Int] = delegator.getReplicasForPartition(zkClient, topic, partition)
[error]                                                                                                        ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:102: value getInSyncReplicasForPartition is not a member of object kafka.utils.ZkUtils
[error]   def getInSyncReplicasForPartition(zkClient: ZkClient, topic: String, partition: Int): Seq[Int] = delegator.getInSyncReplicasForPartition(zkClient, topic, partition)
[error]                                                                                                              ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:104: value getEpochForPartition is not a member of object kafka.utils.ZkUtils
[error]   def getEpochForPartition(zkClient: ZkClient, topic: String, partition: Int): Int = delegator.getEpochForPartition(zkClient, topic, partition)
[error]                                                                                                ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:106: value getLeaderForPartition is not a member of object kafka.utils.ZkUtils
[error]   def getLeaderForPartition(zkClient: ZkClient, topic: String, partition: Int): Option[Int] = delegator.getLeaderForPartition(zkClient, topic, partition)
[error]                                                                                                         ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:108: value setupCommonPaths is not a member of object kafka.utils.ZkUtils
[error]   def setupCommonPaths(zkClient: ZkClient): Unit = delegator.setupCommonPaths(zkClient)
[error]                                                              ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:110: value getLeaderAndIsrForPartition is not a member of object kafka.utils.ZkUtils
[error]   def getLeaderAndIsrForPartition(zkClient: ZkClient, topic: String, partition: Int): Option[LeaderAndIsr] = delegator.getLeaderAndIsrForPartition(zkClient, topic, partition)
[error]                                                                                                                        ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:112: value getAllBrokersInCluster is not a member of object kafka.utils.ZkUtils
[error]   def getAllBrokersInCluster(zkClient: ZkClient): Seq[Broker] = delegator.getAllBrokersInCluster(zkClient)
[error]                                                                           ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:114: value getSortedBrokerList is not a member of object kafka.utils.ZkUtils
[error]   def getSortedBrokerList(zkClient: ZkClient): Seq[Int] = delegator.getSortedBrokerList(zkClient)
[error]                                                                     ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:120: value getController is not a member of object kafka.utils.ZkUtils
[error]   def getController(zkClient: ZkClient): Int = delegator.getController(zkClient)
[error]                                                          ^
[error] /Users/subramanyajoshi/Workspace/imanage/github/KafkaOffsetMonitor/src/main/scala/com/quantifind/utils/ZkUtilsWrapper.scala:124: value getTopicConfigPath is not a member of object kafka.utils.ZkUtils
[error]   def getTopicConfigPath(topic: String): String = delegator.getTopicConfigPath(topic)
[error]                                                             ^
[error] 54 errors found
[error] (compile:compile) Compilation failed
[error] Total time: 6 s, completed 21 Oct, 2016 12:44:22 AM