Path	Lines of Code
config/jmxtrans.xml	113
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/Constants.java	11
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/configuration/IuReplicatorConf.java	10
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/HelixHandler.java	9
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/IHelixManager.java	9
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/ITopicWorkloadWeighter.java	4
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/InstanceTopicPartitionHolder.java	148
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/KafkaBrokerTopicObserver.java	237
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/OnlineOfflineStateFactory.java	58
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/OnlineOfflineStateModel.java	81
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/TopicPartition.java	81
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/TopicPartitionCountObserver.java	91
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/TopicWorkload.java	111
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/WorkloadInfoRetriever.java	216
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/modules/ControllerWorkloadInfo.java	17
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/modules/TopicPartitionLag.java	26
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/modules/WorkerWorkloadInfo.java	12
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/C3QueryUtils.java	110
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/HelixSetupUtils.java	62
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/HelixUtils.java	230
uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/HttpClientUtils.java	137
uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/GraphiteKafkaGauge.java	13
uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/KafkaClusterObserver.java	73
uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/KafkaUReplicatorMetricsReporter.java	152
uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/MetricsReporterConf.java	52
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/ControllerConf.java	981
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/ControllerInstance.java	215
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/ControllerStarter.java	130
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/AutoRebalanceLiveInstanceChangeListener.java	661
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/AutoTopicWhitelistingManager.java	213
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/BackUpHandler.java	4
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/ClusterInfoBackupManager.java	96
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/ControllerStateModelFactory.java	82
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/FileBackUpHandler.java	35
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/GitBackUpHandler.java	88
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/HelixMirrorMakerManager.java	333
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/IdealStateBuilder.java	101
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/ManagerControllerHelix.java	255
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/OffsetMonitor.java	396
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/TopicAssignmentViewBuilder.java	78
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/ControllerRestApplication.java	40
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/AdminRestletResource.java	102
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/HealthCheckRestletResource.java	24
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/MirrorMakerManagerRestletResource.java	117
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/NoProgressTopicPartitionRestletResource.java	53
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicManagementRestletResource.java	219
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicParitionOffsetRestletResource.java	45
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicPartitionBlacklistRestletResource.java	61
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/ValidationRestletResource.java	48
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/util/FileUtils.java	18
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/validation/SourceKafkaClusterValidationManager.java	194
uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/validation/ValidationManager.java	311
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/ManagerConf.java	505
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/ManagerStarter.java	120
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/AdminHelper.java	84
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerException.java	9
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerHelixManager.java	1267
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerLiveInstanceChangeListener.java	95
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerWorkloadSnapshot.java	104
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/IdealStateBuilder.java	181
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerHelixManager.java	274
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerLiveInstanceChangeListener.java	23
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/ManagerRestApplication.java	28
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/AdminRestletResource.java	181
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/HealthCheckRestletResource.java	12
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/TopicManagementRestletResource.java	351
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/utils/ControllerUtils.java	10
uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/validation/KafkaClusterValidationManager.java	41
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/Constants.java	28
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ConsumerFetcherThread.java	217
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ConsumerIterator.java	69
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/CustomizedConsumerConfig.java	54
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/DefaultMessageTransformer.java	33
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/DefaultProducer.java	115
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/FetchedDataChunk.java	22
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/FetcherManager.java	243
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/FetcherManagerGroupByLeaderId.java	56
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/IteratorTemplate.java	53
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/PartitionOffsetInfo.java	50
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ProducerManager.java	58
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ProducerThread.java	170
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/RateLimiterResource.java	40
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/RestletApplication.java	18
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerConf.java	287
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerInstance.java	331
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerStarter.java	137
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerUtils.java	54
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ZookeeperCheckpointManager.java	115
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/helix/ControllerWorkerHelixHandler.java	134
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/helix/ManagerWorkerHelixHandler.java	208
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/interfaces/ICheckPointManager.java	8
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/interfaces/IConsumerFetcherManager.java	12
uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/interfaces/IMessageTransformer.java	6