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-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerException.java 9 2 1953 1842 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/ControllerLiveInstanceChangeListener.java 95 11 2358 1539 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/core/ControllerWorkloadSnapshot.java 104 1 1539 1539 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/WorkerLiveInstanceChangeListener.java 23 6 2358 1842 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/ControllerHelixManager.java 1267 41 2346 1297 46 9 2017-11-01 2020-09-15 xhl1988@gmail.com yayang@uber.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/AdminHelper.java 84 4 1953 1655 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/WorkerHelixManager.java 274 13 2346 1296 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/IdealStateBuilder.java 181 12 2346 1296 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/utils/ControllerUtils.java 10 2 1953 1842 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/ManagerStarter.java 120 12 2358 1655 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/ManagerConf.java 505 14 2358 1618 14 5 2017-10-20 2019-10-30 xhl1988@gmail.com guo.jiwei@immomo.com uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/rest/resources/TopicManagementRestletResource.java 351 15 2358 1624 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 2358 1954 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/resources/AdminRestletResource.java 181 8 1967 1843 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/ManagerRestApplication.java 28 5 2358 1842 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 1778 1655 2 2 2019-05-23 2019-09-23 hongxu@uber.com technoboy@yeah.net uReplicator-Common/src/main/java/com/uber/stream/ureplicator/common/GraphiteKafkaGauge.java 13 1 1708 1708 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/KafkaClusterObserver.java 73 2 1708 1675 2 1 2019-08-01 2019-09-03 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 1708 1655 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 1708 1655 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/kafka/mirrormaker/common/configuration/IuReplicatorConf.java 10 5 2346 1842 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/HelixHandler.java 9 1 1708 1708 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/OnlineOfflineStateModel.java 81 4 2357 1842 4 3 2017-10-21 2019-03-20 xhl1988@gmail.com yayang@uber.com uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/ITopicWorkloadWeighter.java 4 4 2346 1842 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 2346 1539 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/KafkaBrokerTopicObserver.java 237 8 2346 1655 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/TopicPartition.java 81 5 2346 1842 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/IHelixManager.java 9 4 2346 1842 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/InstanceTopicPartitionHolder.java 148 11 2346 1539 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/TopicPartitionCountObserver.java 91 1 1708 1708 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/OnlineOfflineStateFactory.java 58 1 1708 1708 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/WorkloadInfoRetriever.java 216 8 2346 1842 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/utils/HelixUtils.java 230 14 2346 1220 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/C3QueryUtils.java 110 5 2346 1842 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/HelixSetupUtils.java 62 4 2357 1842 4 3 2017-10-21 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 2346 1655 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 1843 1842 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/WorkerWorkloadInfo.java 12 2 1843 1842 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 1843 1585 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/Constants.java 11 3 1861 1604 3 2 2019-03-01 2019-11-13 yayang@uber.com guo.jiwei@immomo.com docker-compose-example5.yml 96 4 1888 1498 4 2 2019-02-02 2020-02-27 43356004+yangy0000@users.noreply.github.com yayang@uber.com docker-compose-example4.yml 71 4 1919 1143 4 2 2019-01-02 2021-02-16 43356004+00sheep00@users.noreply.github.com yayang@uber.com config/jmxtrans.xml 113 1 1861 1861 1 1 2019-03-01 2019-03-01 xhl1988@gmail.com xhl1988@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/WorkerStarter.java 137 2 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/PartitionOffsetInfo.java 50 2 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 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 1038 1032 2 2 2021-06-01 2021-06-07 sil@uber.com laosiaudi@gmail.com uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/OffsetMonitor.java 396 20 2365 1613 29 7 2017-10-13 2019-11-04 xhl1988@gmail.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/BackUpHandler.java 4 4 2713 1842 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/ClusterInfoBackupManager.java 96 10 2713 1842 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/ControllerStateModelFactory.java 82 6 2346 1842 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/TopicAssignmentViewBuilder.java 78 2 1861 1842 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/AutoRebalanceLiveInstanceChangeListener.java 661 21 2713 1708 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/ManagerControllerHelix.java 255 16 2358 1655 16 7 2017-10-20 2019-09-23 zhenmin@uber.com technoboy@yeah.net uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/core/HelixMirrorMakerManager.java 333 24 2713 1604 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/FileBackUpHandler.java 35 9 2713 1669 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/AutoTopicWhitelistingManager.java 213 12 2713 1655 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/GitBackUpHandler.java 88 8 2713 1842 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/IdealStateBuilder.java 101 14 2713 1842 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/ControllerStarter.java 130 16 2713 1708 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/util/FileUtils.java 18 1 1669 1669 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/ControllerConf.java 981 23 2713 1655 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/rest/ControllerRestApplication.java 40 11 2713 1842 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/rest/resources/TopicPartitionBlacklistRestletResource.java 61 1 1861 1861 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/MirrorMakerManagerRestletResource.java 117 10 2366 1868 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/TopicManagementRestletResource.java 219 13 2713 1655 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/TopicParitionOffsetRestletResource.java 45 4 2365 1888 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/ValidationRestletResource.java 48 3 2713 2446 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/HealthCheckRestletResource.java 24 3 2713 1882 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 1888 1877 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/resources/AdminRestletResource.java 102 10 2713 1585 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/validation/SourceKafkaClusterValidationManager.java 194 11 2713 1655 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/validation/ValidationManager.java 311 11 2713 1708 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/ControllerInstance.java 215 13 2357 1655 13 6 2017-10-21 2019-09-23 zhenmin@uber.com technoboy@yeah.net