uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerHelixManager.java (8 lines):
	- line 148: // TODO: make it configurable
	- line 264: // TODO: one instance suppose to have only one route
	- line 411: // TODO: one instance suppose to have only one route
	- line 570: // TODO: one instance suppose to have only one route
	- line 780: // TODO: is it possible to have different route on same host?
	- line 959: // TODO: what if routeId is not continuous
	- line 1248: // TODO: fix status if accidentally expanding a topic to a larger number
	- line 1321: // TODO: delete topic first


uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/TopicManagementRestletResource.java (3 lines):
	- line 80: // TODO: updateCurrentStatus might take a long time
	- line 134: // TODO: add worker information
	- line 157: // TODO: validate src->dst combination


uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/TopicWorkload.java (2 lines):
	- line 103: // TODO: decide which metric to compare
	- line 122: // TODO: decide which metric to compare


uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/FetcherManager.java (2 lines):
	- line 76: // TODO:(yayang) recycle fetcherId from shutdown fetcher thread
	- line 291: // FIXME: propagate topic partition change to controller


uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ProducerThread.java (1 line):
	- line 163: // TODO: add backoff ms for ConsumerTimeoutException


uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/WorkloadInfoRetriever.java (1 line):
	- line 243: // TODO: make it compatible with controller


uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerConf.java (1 line):
	- line 104: // TODO: abstract getProperty to to share with controller/manger conf class


uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/HelixUtils.java (1 line):
	- line 150: // TODO: add metrics and alert on this


uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ZookeeperCheckpointManager.java (1 line):
	- line 46: // TODO: deprecate zookeeper offset checkpoint


uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/KafkaUReplicatorMetricsReporter.java (1 line):
	- line 52: // FIXME: change convention for member variable


uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/AdminRestletResource.java (1 line):
	- line 85: // TODO: separate manager and controller operation


uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/KafkaClusterObserver.java (1 line):
	- line 34: // TODO: implement topic count observer


uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerHelixManager.java (1 line):
	- line 112: // TODO: one instance suppose to have only one partition


uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/AdminHelper.java (1 line):
	- line 64: status.put("hostname", instanceName); //TODO: merge with instanceID change