An overview of contributor trends.
Contributed in past 6 months (a rookie = the first contribution in past year)
Past 30 days (2):
No contributors in past 31 to 90 days.
Past 91 to 180 days (1):
Last contributed more than 6 months ago
| Commits (3m) |
Commit Days |
-
|
2
|
1
|
2
|
3
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
| 67832317+ericzhifengchen@users.noreply.github.com | 9 | 6 |
-
|
|
-
|
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
| chenz@uber.com | 9 | 8 |
-
|
|
|
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
| 43356004+yangy0000@users.noreply.github.com | - | 1 |
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
2 contributors (13 commits):
| # | Contributor |
First Commit |
Latest Commit |
Commits Count |
File Updates (per extension) |
|---|---|---|---|---|---|
| 1. | 67832317+ericzhifengchen@users.noreply.github.com | 2023-12-02 | 2024-03-13 | 7 (53%) | java (61), yml (6), json (4), proto (4), gradle (3) |
| 2. | chenz@uber.com | 2023-12-01 | 2024-03-13 | 6 (46%) | java (121), json (8), proto (8), gradle (6), yaml (4) |
A contributor dependency is detected if two contributors have changed the same files in the past 30 days.
The number on lines shows the number of same files that both persons changed in past 30 days.
| Contributor 1 | Contributor 2 | # shared files | |
|---|---|---|---|
| 1. | 67832317+ericzhifengchen@users.noreply.github.com | chenz@uber.com |
75 shared files
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessageTest.java .buildkite/docker-compose.yml uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java idl/src/main/proto/data/kafka/data-transfer/job_group.proto uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/test/resources/data/extra_workload_one_job_group_overload_workers.json uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessageTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/common/StructuredLoggingTest.java idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest2.java buildSrc/src/main/groovy/uforwarder.java-common-conventions.gradle uforwarder/src/test/resources/data/extra_workload_one_job_group.json uforwarder-core/src/main/resources/workerJobStatus.html uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java uforwarder-core/src/test/resources/base.yaml uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java uforwarder/src/test/resources/data/extra_workload_job_group_scale_one.json uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherCancelTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStubTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactoryTest.java uforwarder/src/test/resources/data/tier5jobs.json uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfigurationTest.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/StateMachineTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImplTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactoryTest.java uforwarder/src/test/resources/base.yaml uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcherTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThreadTest.java uforwarder/build.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/StructuredTagsTest.java settings.gradle uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcherTest.java idl/src/main/proto/data/kafka/data-transfer/job.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManagerTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java idl/src/main/proto/data/kafka/data-transfer/job_status.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfigurationTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTrackerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/InstrumentationTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactoryTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java |
| Contributor | # connections | # commits | |
|---|---|---|---|
| 1. | 67832317+ericzhifengchen@users.noreply.github.com | 1 | 7 |
| 2. | chenz@uber.com | 1 | 6 |
C-median: 1.0
A half of the contributors has more than 1.0 connections, and a half has less than this number.
C-mean: 1.0
An average number of connections a contributor has with other contributors.
C-index: 1.0
There are 1.0 contributors with 1.0 or more connections.
2 contributors (18 commits):
| # | Contributor |
First Commit |
Latest Commit |
Commits Count |
File Updates (per extension) |
|---|---|---|---|---|---|
| 1. | chenz@uber.com | 2023-12-01 | 2024-03-13 | 9 (50%) | java (183), gradle (14), proto (9), json (8), yaml (7) |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | 2023-12-02 | 2024-03-13 | 9 (50%) | java (132), gradle (13), yaml (8), yml (6), proto (5) |
A contributor dependency is detected if two contributors have changed the same files in the past 90 days.
The number on lines shows the number of same files that both persons changed in past 90 days.
| Contributor 1 | Contributor 2 | # shared files | |
|---|---|---|---|
| 1. | 67832317+ericzhifengchen@users.noreply.github.com | chenz@uber.com |
125 shared files
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessageTest.java .buildkite/docker-compose.yml uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java idl/src/main/proto/data/kafka/data-transfer/job_group.proto uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessageTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java uforwarder/src/test/resources/data/extra_workload_one_job_group.json uforwarder-core/src/main/resources/workerJobStatus.html uforwarder-core/src/test/resources/base.yaml uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermit.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java uforwarder/src/test/resources/data/extra_workload_job_group_scale_one.json uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AttributeKey.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/AdminClientTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStubTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactoryTest.java uforwarder/src/test/resources/data/tier5jobs.json uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactoryTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancerTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImplTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactoryTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcherTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThreadTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermitTest.java idl/build.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcherTest.java idl/src/main/proto/data/kafka/data-transfer/job.proto uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManagerTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest.java idl/src/main/proto/data/kafka/data-transfer/job_status.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfigurationTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueueTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueueTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/test/resources/data/extra_workload_one_job_group_overload_workers.json uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java uforwarder/src/main/resources/application-uforwarder-controller.yaml uforwarder-image/docker/Dockerfile uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/common/StructuredLoggingTest.java idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto uforwarder-image/build.gradle uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfigurationTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest2.java buildSrc/src/main/groovy/uforwarder.java-common-conventions.gradle uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java README.md uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherCancelTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcherTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfigurationTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreatorTest.java uforwarder-core/build.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java uforwarder-sample-consumer/build.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiterTest.java ... |
| Contributor | # connections | # commits | |
|---|---|---|---|
| 1. | chenz@uber.com | 1 | 9 |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | 1 | 9 |
C-median: 1.0
A half of the contributors has more than 1.0 connections, and a half has less than this number.
C-mean: 1.0
An average number of connections a contributor has with other contributors.
C-index: 1.0
There are 1.0 contributors with 1.0 or more connections.
3 contributors (24 commits):
| # | Contributor |
First Commit |
Latest Commit |
Commits Count |
|---|---|---|---|---|
| 1. | chenz@uber.com | 2023-12-01 | 2024-03-13 | 13 (54%) |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | 2023-12-02 | 2024-03-13 | 10 (41%) |
| 3. | 43356004+yangy0000@users.noreply.github.com | 2023-12-01 | 2023-12-01 | 1 (4%) |
A contributor dependency is detected if two contributors have changed the same files in the past 180 days.
The number on lines shows the number of same files that both persons changed in past 180 days.
| Contributor 1 | Contributor 2 | # shared files | |
|---|---|---|---|
| 1. | 43356004+yangy0000@users.noreply.github.com | chenz@uber.com |
599 shared files
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleComputer.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/MetricsConfiguration.java buildSrc/build/resources/main/META-INF/gradle-plugins/uforwarder.java-library-conventions.properties uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/GrpcControllerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/TimestampUtils.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/TagsTest.java uforwarder-core/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaClusterResolver.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/utils/NodeConfigurationUtilsTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25.class uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorker.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherFactory.java uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/DataTransferMaster.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponseTest.java uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/Constants.java buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure7$_closure14$_closure15$_closure17.class uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorAutoConfiguration2.java uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerBytesServerMethodDefinition.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManagerTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiterTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure7$_closure14.class uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/StoreConfigurationTest.java admin-client/src/main/java/com/uber/data/kafka/clients/admin/Admin.java uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure9.class buildSrc/build/groovy-dsl-plugins/output/plugin-requests-staging/cp_precompiled_UforwarderJavaLibraryConventions.class uforwarder/src/test/resources/data/tier5jobs.json uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactoryTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java fievel-common/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancerTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/IdProvider.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerClient.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/ControllableTest.java idl/src/main/proto/data/kafka/data-transfer/job_snapshot.proto uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/JobStatusJsonTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/NoopClosableTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/OutboundMessageLimiter.java buildSrc/build/pluginDescriptors/uforwarder.java-library-conventions.properties buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure4.class uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/MasterJobsJson.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcher.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStoreIntegrationTest.java uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderContainer.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineMetricPublisherTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancerTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/RoutingUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/InflightLimiter.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/ThrowingRunnable.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManagerAutoConfiguration.java buildSrc/build/tmp/jar/MANIFEST.MF uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcCallOptionsExtractorTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10.class buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure21$_closure23$_closure24.class uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25.class uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactoryTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/VersionedProtoTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-requests-staging/cp_precompiled_UforwarderJavaCommonConventions.class buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25$_closure26$_closure27.class uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/JobStatusHtml.java uforwarder-core/src/main/resources/masterJobs.html uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/KafkaOffsetCommitterConfigurationTest1.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherFactoryTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStore.java uforwarder-core/src/main/resources/masters.html uforwarder-image/docker/Dockerfile uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/ThroughputTracker.java buildSrc/build.gradle buildSrc/build/groovy-dsl-plugins/output/plugin-requests/uforwarder.java-library-conventions/cp_precompiled_UforwarderJavaLibraryConventions$_run_closure1.class buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure7.class uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/Throughput.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/UForwarderTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancerAutoConfiguration2.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java buildSrc/build/groovy-dsl-plugins/output/plugin-requests/uforwarder.java-library-conventions/cp_precompiled_UforwarderJavaLibraryConventions.class uforwarder/src/test/resources/data/processing.py uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/ShadowRebalancerDelegateTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25$_closure26$_closure27$_closure28.class uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/DataTransferWorker.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetector.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java idl/src/main/proto/data/kafka/data-transfer/worker.proto uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcResponse.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/processors/TranslatingPushPushProcessor.java ... |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | chenz@uber.com |
141 shared files
.buildkite/udj/publish-to-artifactory.yaml uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponseTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java uforwarder/src/test/resources/data/tier5jobs.json uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java gradlew.bat uforwarder-image/docker/Dockerfile uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java uforwarder-core/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImplTest.java uforwarder/src/test/resources/base.yaml uforwarder/build.gradle settings.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumer.java .gitattributes idl/src/main/proto/data/kafka/data-transfer/job_group.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessageTest.java uforwarder-core/src/main/resources/workerJobStatus.html uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImplTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactoryTest.java idl/build.gradle uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java idl/src/main/proto/data/kafka/data-transfer/job.proto uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManagerTest.java gradle.properties idl/src/main/proto/data/kafka/data-transfer/job_status.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfigurationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java uforwarder-image/build.gradle uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest2.java buildSrc/src/main/groovy/uforwarder.java-common-conventions.gradle uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java README.md uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfigurationTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreatorTest.java uforwarder-sample-consumer/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManagerTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTrackerTest.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/InstrumentationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactoryTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessageTest.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerMetadataTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java uforwarder-core/src/test/resources/base.yaml uforwarder/src/test/resources/data/extra_workload_job_group_scale_one.json uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStubTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactoryTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactoryTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java .buildkite/udj/gradle-build.yaml uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueueTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueueTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfigurationTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherCancelTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java .gitignore ... |
| 3. | 43356004+yangy0000@users.noreply.github.com | 67832317+ericzhifengchen@users.noreply.github.com |
113 shared files
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponseTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java uforwarder/src/test/resources/data/tier5jobs.json uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java uforwarder-image/docker/Dockerfile uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java uforwarder-core/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImplTest.java uforwarder/src/test/resources/base.yaml uforwarder/build.gradle settings.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java idl/src/main/proto/data/kafka/data-transfer/job_group.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessageTest.java uforwarder-core/src/main/resources/workerJobStatus.html uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImplTest.java idl/build.gradle uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java idl/src/main/proto/data/kafka/data-transfer/job.proto uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManagerTest.java gradle.properties idl/src/main/proto/data/kafka/data-transfer/job_status.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfigurationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java uforwarder-image/build.gradle uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest2.java buildSrc/src/main/groovy/uforwarder.java-common-conventions.gradle uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java README.md uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfigurationTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreatorTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManagerTest.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/InstrumentationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactoryTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessageTest.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerMetadataTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java uforwarder-core/src/test/resources/base.yaml uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStubTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactoryTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueueTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueueTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfigurationTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherCancelTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java .gitignore uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/StateMachineTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcherTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThreadTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcherTest.java uforwarder/src/main/resources/application-uforwarder-controller.yaml uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/common/StructuredLoggingTest.java ... |
| Contributor | # connections | # commits | |
|---|---|---|---|
| 1. | chenz@uber.com | 2 | 13 |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | 2 | 10 |
| 3. | 43356004+yangy0000@users.noreply.github.com | 2 | 1 |
C-median: 2.0
A half of the contributors has more than 2.0 connections, and a half has less than this number.
C-mean: 2.0
An average number of connections a contributor has with other contributors.
C-index: 2.0
There are 2.0 contributors with 2.0 or more connections.
3 contributors (24 commits):
| # | Contributor |
First Commit |
Latest Commit |
Commits Count |
|---|---|---|---|---|
| 1. | chenz@uber.com | 2023-12-01 | 2024-03-13 | 13 (54%) |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | 2023-12-02 | 2024-03-13 | 10 (41%) |
| 3. | 43356004+yangy0000@users.noreply.github.com | 2023-12-01 | 2023-12-01 | 1 (4%) |
A contributor dependency is detected if two contributors have changed the same files in the past 365 days.
The number on lines shows the number of same files that both persons changed in past 365 days.
| Contributor 1 | Contributor 2 | # shared files | |
|---|---|---|---|
| 1. | 43356004+yangy0000@users.noreply.github.com | chenz@uber.com |
599 shared files
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleComputer.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/MetricsConfiguration.java buildSrc/build/resources/main/META-INF/gradle-plugins/uforwarder.java-library-conventions.properties uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/GrpcControllerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/TimestampUtils.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/TagsTest.java uforwarder-core/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaClusterResolver.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/utils/NodeConfigurationUtilsTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25.class uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorker.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherFactory.java uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/DataTransferMaster.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponseTest.java uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/Constants.java buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure7$_closure14$_closure15$_closure17.class uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorAutoConfiguration2.java uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerBytesServerMethodDefinition.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManagerTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiterTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure7$_closure14.class uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/StoreConfigurationTest.java admin-client/src/main/java/com/uber/data/kafka/clients/admin/Admin.java uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure9.class buildSrc/build/groovy-dsl-plugins/output/plugin-requests-staging/cp_precompiled_UforwarderJavaLibraryConventions.class uforwarder/src/test/resources/data/tier5jobs.json uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactoryTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java fievel-common/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancerTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/IdProvider.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerClient.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/ControllableTest.java idl/src/main/proto/data/kafka/data-transfer/job_snapshot.proto uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/JobStatusJsonTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/NoopClosableTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/OutboundMessageLimiter.java buildSrc/build/pluginDescriptors/uforwarder.java-library-conventions.properties buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure4.class uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/MasterJobsJson.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcher.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStoreIntegrationTest.java uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderContainer.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineMetricPublisherTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancerTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/RoutingUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/InflightLimiter.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/ThrowingRunnable.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManagerAutoConfiguration.java buildSrc/build/tmp/jar/MANIFEST.MF uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcCallOptionsExtractorTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10.class buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure21$_closure23$_closure24.class uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25.class uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactoryTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/VersionedProtoTest.java buildSrc/build/groovy-dsl-plugins/output/plugin-requests-staging/cp_precompiled_UforwarderJavaCommonConventions.class buildSrc/build/groovy-dsl-plugins/work/classes/uforwarder.java-common-conventions/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25$_closure26$_closure27.class uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/JobStatusHtml.java uforwarder-core/src/main/resources/masterJobs.html uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/KafkaOffsetCommitterConfigurationTest1.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherFactoryTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStore.java uforwarder-core/src/main/resources/masters.html uforwarder-image/docker/Dockerfile uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/ThroughputTracker.java buildSrc/build.gradle buildSrc/build/groovy-dsl-plugins/output/plugin-requests/uforwarder.java-library-conventions/cp_precompiled_UforwarderJavaLibraryConventions$_run_closure1.class buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure7.class uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/Throughput.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/UForwarderTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancerAutoConfiguration2.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java buildSrc/build/groovy-dsl-plugins/output/plugin-requests/uforwarder.java-library-conventions/cp_precompiled_UforwarderJavaLibraryConventions.class uforwarder/src/test/resources/data/processing.py uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/ShadowRebalancerDelegateTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java buildSrc/build/groovy-dsl-plugins/output/plugin-classes/precompiled_UforwarderJavaCommonConventions$_run_closure10$_closure22$_closure25$_closure26$_closure27$_closure28.class uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/DataTransferWorker.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetector.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java idl/src/main/proto/data/kafka/data-transfer/worker.proto uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcResponse.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/processors/TranslatingPushPushProcessor.java ... |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | chenz@uber.com |
141 shared files
.buildkite/udj/publish-to-artifactory.yaml uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponseTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java uforwarder/src/test/resources/data/tier5jobs.json uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java gradlew.bat uforwarder-image/docker/Dockerfile uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java uforwarder-core/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImplTest.java uforwarder/src/test/resources/base.yaml uforwarder/build.gradle settings.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumer.java .gitattributes idl/src/main/proto/data/kafka/data-transfer/job_group.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessageTest.java uforwarder-core/src/main/resources/workerJobStatus.html uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImplTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactoryTest.java idl/build.gradle uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java idl/src/main/proto/data/kafka/data-transfer/job.proto uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManagerTest.java gradle.properties idl/src/main/proto/data/kafka/data-transfer/job_status.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfigurationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java uforwarder-image/build.gradle uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest2.java buildSrc/src/main/groovy/uforwarder.java-common-conventions.gradle uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java README.md uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfigurationTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreatorTest.java uforwarder-sample-consumer/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManagerTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTrackerTest.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/InstrumentationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactoryTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessageTest.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerMetadataTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java uforwarder-core/src/test/resources/base.yaml uforwarder/src/test/resources/data/extra_workload_job_group_scale_one.json uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStubTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactoryTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactoryTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java .buildkite/udj/gradle-build.yaml uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueueTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueueTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfigurationTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherCancelTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java .gitignore ... |
| 3. | 43356004+yangy0000@users.noreply.github.com | 67832317+ericzhifengchen@users.noreply.github.com |
113 shared files
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponseTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java uforwarder/src/test/resources/data/tier5jobs.json uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java uforwarder-image/docker/Dockerfile uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java uforwarder-core/build.gradle uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImplTest.java uforwarder/src/test/resources/base.yaml uforwarder/build.gradle settings.gradle uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java idl/src/main/proto/data/kafka/data-transfer/job_group.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessageTest.java uforwarder-core/src/main/resources/workerJobStatus.html uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImplTest.java idl/build.gradle uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java idl/src/main/proto/data/kafka/data-transfer/job.proto uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManagerTest.java gradle.properties idl/src/main/proto/data/kafka/data-transfer/job_status.proto uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfigurationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java uforwarder-image/build.gradle uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest2.java buildSrc/src/main/groovy/uforwarder.java-common-conventions.gradle uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java README.md uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfigurationTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreatorTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManagerTest.java instrumentation/src/test/java/com/uber/data/kafka/instrumentation/InstrumentationTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactoryTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessageTest.java uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerMetadataTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java uforwarder-core/src/test/resources/base.yaml uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStubTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactoryTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancerTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueueTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueueTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfigurationTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherCancelTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManager.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java .gitignore uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/StateMachineTest.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcherTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThreadTest.java uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherTest.java uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcherTest.java uforwarder/src/main/resources/application-uforwarder-controller.yaml uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/common/StructuredLoggingTest.java ... |
| Contributor | # connections | # commits | |
|---|---|---|---|
| 1. | chenz@uber.com | 2 | 13 |
| 2. | 67832317+ericzhifengchen@users.noreply.github.com | 2 | 10 |
| 3. | 43356004+yangy0000@users.noreply.github.com | 2 | 1 |
C-median: 2.0
A half of the contributors has more than 2.0 connections, and a half has less than this number.
C-mean: 2.0
An average number of connections a contributor has with other contributors.
C-index: 2.0
There are 2.0 contributors with 2.0 or more connections.