path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/ValidationRestletResource.java 48 3 3458 3191 3 3 2016-10-30 2017-07-24 hongxu@uber.com xhl1988@gmail.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicParitionOffsetRestletResource.java 45 4 3110 2633 4 4 2017-10-13 2019-02-02 xhl1988@gmail.com 43356004+yangy0000@users.noreply.github.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/MirrorMakerManagerRestletResource.java 117 10 3111 2613 10 4 2017-10-12 2019-02-22 xhl1988@gmail.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicPartitionBlacklistRestletResource.java 61 1 2606 2606 1 1 2019-03-01 2019-03-01 yayang@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/AdminRestletResource.java 102 10 3458 2330 11 7 2016-10-30 2019-12-02 hongxu@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicManagementRestletResource.java 219 12 3458 2400 14 8 2016-10-30 2019-09-23 hongxu@uber.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/HealthCheckRestletResource.java 24 3 3458 2627 3 3 2016-10-30 2019-02-08 hongxu@uber.com 43356004+yangy0000@users.noreply.github.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/NoProgressTopicPartitionRestletResource.java 53 3 2633 2622 3 2 2019-02-02 2019-02-13 43356004+yangy0000@users.noreply.github.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/ControllerRestApplication.java 40 11 3458 2587 12 6 2016-10-30 2019-03-20 hongxu@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/ControllerConf.java 981 22 3458 2400 31 9 2016-10-30 2019-09-23 hongxu@uber.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/util/FileUtils.java 18 1 2414 2414 1 1 2019-09-09 2019-09-09 guo.jiwei@immomo.com guo.jiwei@immomo.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/ControllerInstance.java 215 13 3103 2400 13 6 2017-10-20 2019-09-23 zhenmin@uber.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/ControllerStarter.java 130 16 3458 2453 18 8 2016-10-30 2019-08-01 hongxu@uber.com 43356004+yangy0000@users.noreply.github.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/validation/ValidationManager.java 311 11 3458 2453 12 7 2016-10-30 2019-08-01 hongxu@uber.com 43356004+yangy0000@users.noreply.github.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/validation/SourceKafkaClusterValidationManager.java 194 11 3458 2400 12 8 2016-10-30 2019-09-23 hongxu@uber.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/HelixMirrorMakerManager.java 333 24 3458 2349 28 8 2016-10-30 2019-11-13 hongxu@uber.com guo.jiwei@immomo.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/AutoTopicWhitelistingManager.java 213 12 3458 2400 13 8 2016-10-30 2019-09-23 hongxu@uber.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/BackUpHandler.java 4 4 3458 2587 4 4 2016-10-30 2019-03-20 hongxu@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/FileBackUpHandler.java 35 9 3458 2414 10 7 2016-10-30 2019-09-09 hongxu@uber.com guo.jiwei@immomo.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/ControllerStateModelFactory.java 82 6 3091 2587 6 3 2017-11-01 2019-03-20 zhenmin@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/AutoRebalanceLiveInstanceChangeListener.java 661 22 3458 2453 28 7 2016-10-30 2019-08-01 hongxu@uber.com 43356004+yangy0000@users.noreply.github.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/TopicAssignmentViewBuilder.java 78 2 2606 2587 2 1 2019-03-01 2019-03-20 yayang@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/IdealStateBuilder.java 101 14 3458 2587 18 6 2016-10-30 2019-03-20 hongxu@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/ClusterInfoBackupManager.java 96 10 3458 2587 11 6 2016-10-30 2019-03-20 hongxu@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/OffsetMonitor.java 396 22 3111 2358 29 7 2017-10-12 2019-11-04 xhl1988@gmail.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/GitBackUpHandler.java 88 8 3458 2587 9 6 2016-10-30 2019-03-20 hongxu@uber.com yayang@uber.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/ManagerControllerHelix.java 255 16 3103 2400 16 7 2017-10-20 2019-09-23 zhenmin@uber.com technoboy@yeah.net uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/PartitionOffsetInfo.java 50 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/FetchedDataChunk.java 22 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ProducerManager.java 58 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerInstance.java 331 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/helix/ControllerWorkerHelixHandler.java 134 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/helix/ManagerWorkerHelixHandler.java 208 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/RateLimiterResource.java 40 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ProducerThread.java 170 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ZookeeperCheckpointManager.java 115 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerStarter.java 137 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ConsumerFetcherThread.java 217 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerUtils.java 54 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/CustomizedConsumerConfig.java 54 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/Constants.java 28 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/DefaultProducer.java 115 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerConf.java 287 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/interfaces/IConsumerFetcherManager.java 12 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/interfaces/IMessageTransformer.java 6 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/interfaces/ICheckPointManager.java 8 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/DefaultMessageTransformer.java 33 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/RestletApplication.java 18 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ConsumerIterator.java 69 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/FetcherManagerGroupByLeaderId.java 56 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/FetcherManager.java 243 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/IteratorTemplate.java 53 2 1783 1777 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/HelixUtils.java 230 14 3091 1965 14 6 2017-11-01 2020-12-01 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/HelixSetupUtils.java 62 4 3103 2587 4 3 2017-10-20 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/C3QueryUtils.java 110 5 3091 2587 5 3 2017-11-01 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/utils/HttpClientUtils.java 137 8 3091 2400 8 5 2017-11-01 2019-09-23 xhl1988@gmail.com technoboy@yeah.net uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/modules/TopicPartitionLag.java 26 2 2588 2587 2 1 2019-03-19 2019-03-20 yayang@uber.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/modules/ControllerWorkloadInfo.java 17 3 2588 2330 3 1 2019-03-19 2019-12-02 yayang@uber.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/modules/WorkerWorkloadInfo.java 12 2 2588 2587 2 1 2019-03-19 2019-03-20 yayang@uber.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/Constants.java 11 3 2606 2349 3 2 2019-03-01 2019-11-13 yayang@uber.com guo.jiwei@immomo.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/configuration/IuReplicatorConf.java 10 5 3091 2587 5 3 2017-11-01 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/TopicPartition.java 81 5 3091 2587 5 3 2017-11-01 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/OnlineOfflineStateFactory.java 58 1 2453 2453 1 1 2019-08-01 2019-08-01 43356004+yangy0000@users.noreply.github.com 43356004+yangy0000@users.noreply.github.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/ITopicWorkloadWeighter.java 4 4 3091 2587 4 3 2017-11-01 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/TopicWorkload.java 111 6 3091 2284 6 3 2017-11-01 2020-01-17 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/WorkloadInfoRetriever.java 216 8 3091 2587 8 5 2017-11-01 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/KafkaBrokerTopicObserver.java 237 8 3091 2400 8 4 2017-11-01 2019-09-23 xhl1988@gmail.com technoboy@yeah.net uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/InstanceTopicPartitionHolder.java 148 11 3091 2284 11 3 2017-11-01 2020-01-17 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/HelixHandler.java 9 1 2453 2453 1 1 2019-08-01 2019-08-01 43356004+yangy0000@users.noreply.github.com 43356004+yangy0000@users.noreply.github.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/IHelixManager.java 9 4 3091 2587 4 3 2017-11-01 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/OnlineOfflineStateModel.java 81 4 3103 2587 4 3 2017-10-20 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/TopicPartitionCountObserver.java 91 1 2453 2453 1 1 2019-08-01 2019-08-01 43356004+yangy0000@users.noreply.github.com 43356004+yangy0000@users.noreply.github.com uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/GraphiteKafkaGauge.java 13 1 2453 2453 1 1 2019-08-01 2019-08-01 43356004+yangy0000@users.noreply.github.com 43356004+yangy0000@users.noreply.github.com uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/KafkaUReplicatorMetricsReporter.java 152 3 2453 2400 3 2 2019-08-01 2019-09-23 43356004+yangy0000@users.noreply.github.com technoboy@yeah.net uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/MetricsReporterConf.java 52 2 2453 2400 2 2 2019-08-01 2019-09-23 43356004+yangy0000@users.noreply.github.com technoboy@yeah.net uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/KafkaClusterObserver.java 73 2 2453 2420 2 1 2019-08-01 2019-09-03 43356004+yangy0000@users.noreply.github.com 43356004+yangy0000@users.noreply.github.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/ManagerStarter.java 120 12 3103 2400 12 6 2017-10-20 2019-09-23 xhl1988@gmail.com technoboy@yeah.net uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/utils/ControllerUtils.java 10 2 2698 2587 2 2 2018-11-29 2019-03-20 xdong@uber.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/AdminRestletResource.java 181 8 2712 2588 8 5 2018-11-15 2019-03-19 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/TopicManagementRestletResource.java 351 15 3103 2369 16 8 2017-10-20 2019-10-24 xhl1988@gmail.com guo.jiwei@immomo.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/HealthCheckRestletResource.java 12 4 3103 2699 4 3 2017-10-20 2018-11-28 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/ManagerRestApplication.java 28 5 3103 2587 5 3 2017-10-20 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/validation/KafkaClusterValidationManager.java 41 2 2524 2400 2 2 2019-05-22 2019-09-23 hongxu@uber.com technoboy@yeah.net uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerHelixManager.java 274 13 3091 2042 13 4 2017-11-01 2020-09-15 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerWorkloadSnapshot.java 104 1 2284 2284 1 1 2020-01-17 2020-01-17 yayang@uber.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/IdealStateBuilder.java 181 13 3091 2041 13 4 2017-11-01 2020-09-16 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerException.java 9 2 2698 2587 2 2 2018-11-29 2019-03-20 xdong@uber.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/WorkerLiveInstanceChangeListener.java 23 6 3103 2587 6 3 2017-10-20 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/AdminHelper.java 84 4 2698 2400 4 4 2018-11-29 2019-09-23 xdong@uber.com technoboy@yeah.net uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerHelixManager.java 1267 42 3091 2043 46 9 2017-11-01 2020-09-14 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerLiveInstanceChangeListener.java 95 11 3103 2284 11 5 2017-10-20 2020-01-17 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/ManagerConf.java 505 14 3103 2363 14 5 2017-10-20 2019-10-30 xhl1988@gmail.com guo.jiwei@immomo.com config/jmxtrans.xml 113 1 2606 2606 1 1 2019-03-01 2019-03-01 xhl1988@gmail.com xhl1988@gmail.com