uber / uForwarder
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 291 files with 25,887 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 3 files changed 6-20 times (918 lines of code)
    • 288 files changed 1-5 times (24,969 lines of code)
0% | 0% | 0% | 3% | 96%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 291 files with 25,887 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 273 files changed by 2-5 contributors (25,154 lines of code)
    • 18 files changed by 1 contributor (733 lines of code)
0% | 0% | 0% | 97% | 2%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, gradle, proto, json, yaml, html, sh, md, properties, gitignore, py, gitattributes, txt, bat, xml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 3% | 96%
proto0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
uforwarder0% | 0% | 0% | 6% | 93%
uforwarder-core0% | 0% | 0% | 1% | 98%
idl0% | 0% | 0% | 0% | 100%
instrumentation0% | 0% | 0% | 0% | 100%
uforwarder-container0% | 0% | 0% | 0% | 100%
uforwarder-client0% | 0% | 0% | 0% | 100%
uforwarder-sample-consumer0% | 0% | 0% | 0% | 100%
fievel-common0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 259 10 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 539 24 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 120 15 2023-12-01 2024-12-06 6 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredLogging.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 49 11 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 169 8 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1077 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1095 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredFields.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 24 - 2023-12-01 2024-04-23 4 4 43356004+yangy0000@users.no... yayang@uber.com
NetworkUtils.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 54 5 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
InflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 55 6 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredTags.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 73 17 2023-12-01 2024-04-23 4 4 43356004+yangy0000@users.no... yayang@uber.com
application-uforwarder-controller.yaml
in uforwarder/src/main/resources
 96 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UForwarderWorkerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 143 6 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
DispatcherMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 166 7 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 337 14 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 359 18 2023-12-01 2024-04-24 4 4 43356004+yangy0000@users.no... yayang@uber.com
proto
job.proto
in idl/src/main/proto/data/kafka/data-transfer
 410 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
FievelTestBase.java
in fievel-common/src/main/java/com/uber/fievel/testing/base
 2 - 2023-12-01 2024-01-08 3 2 43356004+yangy0000@users.no... chenz@uber.com
UForwarderControllerContainer.java
in uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container
 16 2 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
SampleConsumerHandler.java
in uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder
 25 1 2024-01-08 2024-04-08 3 3 67832317+ericzhifengchen@us... 67832317+ericzhifengchen@us...
DispatcherResponse.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 42 4 2023-12-01 2024-04-24 3 3 43356004+yangy0000@users.no... yayang@uber.com
ProcessorFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 45 2 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AbstractInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 49 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
application-uforwarder-worker.yaml
in uforwarder/src/main/resources
 55 - 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ControllerAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 56 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 68 18 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AdaptiveInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 75 6 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 86 2 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
WorkersJson.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 86 1 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
DlqTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 89 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
proto
master_worker_service.proto
in idl/src/main/proto/data/kafka/data-transfer
 93 - 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancerConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 102 24 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
BootstrapLongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 106 11 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 107 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
PipelineFactoryImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 107 2 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
OriginalTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 110 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RetryTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 123 4 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 162 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 178 - 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
TracedConsumerRecord.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 179 9 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
BatchJobCreator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 192 6 2023-12-01 2024-01-26 3 3 43356004+yangy0000@users.no... chenz@uber.com
AsyncInflightLimiterAdapter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 212 18 2024-04-23 2024-12-06 3 2 yayang@uber.com chenhaifeng88888@gmail.com
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 222 19 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 224 51 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
MessageStub.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 236 17 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
JobManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager
 254 8 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 264 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 539 24 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 259 10 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 120 15 2023-12-01 2024-12-06 6 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredLogging.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 49 11 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1077 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 169 8 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1095 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
proto
job.proto
in idl/src/main/proto/data/kafka/data-transfer
 410 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 337 14 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
DispatcherMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 166 7 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UForwarderWorkerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 143 6 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
application-uforwarder-controller.yaml
in uforwarder/src/main/resources
 96 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
InflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 55 6 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
NetworkUtils.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 54 5 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredTags.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 73 17 2023-12-01 2024-04-23 4 4 43356004+yangy0000@users.no... yayang@uber.com
StructuredFields.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 24 - 2023-12-01 2024-04-23 4 4 43356004+yangy0000@users.no... yayang@uber.com
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 359 18 2023-12-01 2024-04-24 4 4 43356004+yangy0000@users.no... yayang@uber.com
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 178 - 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RebalancerConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 102 24 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 68 18 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 107 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
DlqTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 89 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
OriginalTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 110 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RetryTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 123 4 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AbstractInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 49 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
BootstrapLongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 106 11 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AdaptiveInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 75 6 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 323 25 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 45 2 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 433 27 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 352 27 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
application-uforwarder-worker.yaml
in uforwarder/src/main/resources
 55 - 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 224 51 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 222 19 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 264 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
WorkersJson.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 86 1 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
TracedConsumerRecord.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 179 9 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 86 2 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ControllerAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 56 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
JobManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager
 254 8 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 162 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
proto
master_worker_service.proto
in idl/src/main/proto/data/kafka/data-transfer
 93 - 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
DispatcherResponse.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 42 4 2023-12-01 2024-04-24 3 3 43356004+yangy0000@users.no... yayang@uber.com
PipelineFactoryImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 107 2 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
UnprocessedMessageManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 289 24 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
MessageStub.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 236 17 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
AbstractRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 453 10 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KafkaDelayProcessManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 158 6 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
JobGroupAndWorkerPodifier.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 101 3 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
ConsoleMatcher.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 63 7 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
MasterManagementAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 52 7 2024-05-18 2024-05-18 1 1 yayang@uber.com yayang@uber.com
WorkerManagementAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 40 5 2024-05-18 2024-05-18 1 1 yayang@uber.com yayang@uber.com
CompositeFilter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter
 39 4 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
DelayProcessManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 38 5 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
JobPodPlacementProvider.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 38 5 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
ApplicationReadyListener.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 37 6 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
NodeAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 35 3 2024-05-18 2024-05-18 1 1 yayang@uber.com yayang@uber.com
PodAwareRebalanceGroup.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 33 4 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
OriginalClusterFilter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter
 22 4 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
NodeConfigurationUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/utils
 20 2 2024-05-18 2024-05-18 1 1 yayang@uber.com yayang@uber.com
PodUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 19 2 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
TypeRegistryAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 13 - 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
Filter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter
 11 - 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
NodeUrlResolver.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 9 1 2024-05-18 2024-05-18 1 1 yayang@uber.com yayang@uber.com
PodIsolationStatus.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils
 5 - 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 396 14 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerWorkerService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 326 9 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
TTLDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 241 16 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
masterJobs.html
in uforwarder-core/src/main/resources
 234 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ZKStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 233 14 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerAdminService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 231 7 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
workerJobs.html
in uforwarder-core/src/main/resources
 228 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AsyncInflightLimiterAdapter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 212 18 2024-04-23 2024-12-06 3 2 yayang@uber.com chenhaifeng88888@gmail.com
Instrument.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 204 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
LeaderSelector.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator
 186 10 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 178 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaDispatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 165 6 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AutoScalarConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 146 33 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
StubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 145 15 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
HibernatingJobRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 142 6 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
RebalancingJobGroup.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 134 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerClient.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 130 9 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
BufferedWriteDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 130 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
workers.html
in uforwarder-core/src/main/resources
 123 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaCheckpointManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 114 6 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
masters.html
in uforwarder-core/src/main/resources
 107 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobThroughputMonitor.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 104 8 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ScaleWindow.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 102 12 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
LoggingAndMetricsStoreDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 98 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
SampleConsumerAutoConfiguration.java
in uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder
 94 4 2024-01-08 2024-01-08 1 2 67832317+ericzhifengchen@us... chenz@uber.com
ShadowRebalancerDelegateImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 89 8 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaDispatcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 89 16 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
LocalStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 87 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
WindowedAggregator.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 85 8 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
proto
master_admin_service.proto
in idl/src/main/proto/data/kafka/data-transfer
 81 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaAdminClientConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 81 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AckManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 78 7 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Correlations

File Size vs. Number of Changes: 291 points

uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 1095 lines of code y: 5 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/DelayProcessManager.java x: 38 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java x: 158 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 86 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java x: 89 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java x: 107 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java x: 110 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java x: 123 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 254 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java x: 102 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 259 lines of code y: 8 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java x: 539 lines of code y: 8 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java x: 68 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/DynamicConfiguration.java x: 43 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/PodIsolationStatus.java x: 5 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 49 lines of code y: 5 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java x: 169 lines of code y: 5 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredLogging.java x: 224 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/JobGroupAndWorkerPodifier.java x: 101 lines of code y: 1 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 54 lines of code y: 4 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java x: 417 lines of code y: 2 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java x: 51 lines of code y: 2 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/ConsoleMatcher.java x: 63 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/UForwarderAppType.java x: 6 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/ApplicationReadyListener.java x: 37 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java x: 143 lines of code y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/Filter.java x: 11 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/OriginalClusterFilter.java x: 22 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 1077 lines of code y: 5 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java x: 45 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactory.java x: 46 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/SerializerType.java x: 29 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/StoreAutoConfiguration.java x: 167 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TypeRegistryAutoConfiguration.java x: 13 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JobUtils.java x: 222 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/Rebalancer.java x: 162 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 337 lines of code y: 4 # changes uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 264 lines of code y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java x: 433 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AbstractInflightLimiter.java x: 49 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AdaptiveInflightLimiter.java x: 75 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AsyncInflightLimiterAdapter.java x: 212 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/BootstrapLongFixedInflightLimiter.java x: 106 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java x: 113 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilter.java x: 20 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilterChain.java x: 62 lines of code y: 2 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java x: 100 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/ShutdownableThread.java x: 96 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 248 lines of code y: 5 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 323 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/PodAwareRebalanceGroup.java x: 33 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java x: 179 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 120 lines of code y: 6 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 352 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java x: 200 lines of code y: 2 # changes idl/src/main/proto/data/kafka/data-transfer/job.proto x: 410 lines of code y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 166 lines of code y: 4 # changes uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/MetadataAdapter.java x: 80 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java x: 264 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/VegasAdaptiveInflightLimiter.java x: 54 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/GrpcServerRunner.java x: 49 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerAutoConfiguration.java x: 56 lines of code y: 3 # changes uforwarder/src/main/resources/application-uforwarder-controller.yaml x: 96 lines of code y: 4 # changes uforwarder/src/main/resources/application-uforwarder-worker.yaml x: 55 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/PodUtils.java x: 19 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/NodeAutoConfiguration.java x: 35 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/MasterManagementAutoConfiguration.java x: 52 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/NodeUrlResolver.java x: 9 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/WorkerManagementAutoConfiguration.java x: 40 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/utils/NodeConfigurationUtils.java x: 20 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 359 lines of code y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java x: 42 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/CheckpointInfo.java x: 52 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 24 lines of code y: 4 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 73 lines of code y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetector.java x: 69 lines of code y: 2 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java x: 25 lines of code y: 3 # changes idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 93 lines of code y: 3 # changes instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 402 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java x: 101 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 129 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 149 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 409 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 60 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 10 lines of code y: 2 # changes uforwarder-core/src/main/resources/workerJobStatus.html x: 197 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 31 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 33 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 146 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 236 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 289 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/AdminClient.java x: 75 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java x: 192 lines of code y: 3 # changes uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainer.java x: 16 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java x: 19 lines of code y: 2 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java x: 94 lines of code y: 1 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java x: 47 lines of code y: 1 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java x: 51 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java x: 40 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java x: 453 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java x: 58 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java x: 248 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/Attribute.java x: 25 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java x: 258 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java x: 208 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java x: 222 lines of code y: 2 # changes fievel-common/src/main/java/com/uber/fievel/testing/base/FievelTestBase.java x: 2 lines of code y: 3 # changes idl/src/main/proto/data/kafka/data-transfer/debug.proto x: 59 lines of code y: 1 # changes idl/src/main/proto/data/kafka/data-transfer/job_snapshot.proto x: 16 lines of code y: 1 # changes idl/src/main/proto/data/kafka/data-transfer/master_admin_service.proto x: 81 lines of code y: 1 # changes idl/src/main/proto/data/kafka/messaging-consumer/offset_mapping.proto x: 72 lines of code y: 1 # changes idl/src/main/proto/data/kafka/messaging-consumer/offsets.proto x: 55 lines of code y: 1 # changes instrumentation/src/main/java/com/uber/data/kafka/instrumentation/BiConsumerConverter.java x: 15 lines of code y: 1 # changes instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java x: 204 lines of code y: 1 # changes uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponse.java x: 48 lines of code y: 1 # changes uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderContainer.java x: 28 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/HostResolver.java x: 7 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaUtils.java x: 31 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/ProtoSerializationFactory.java x: 26 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/context/ContextManager.java x: 45 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalarAutoConfiguration.java x: 42 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalarConfiguration.java x: 146 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobThroughputMonitor.java x: 104 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleState.java x: 178 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator/LeaderSelector.java x: 186 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorWithOffsets.java x: 64 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/WorkerManager.java x: 71 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancingJobGroup.java x: 134 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java x: 231 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java x: 326 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecorator.java x: 130 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java x: 87 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecorator.java x: 98 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecorator.java x: 241 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStore.java x: 233 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/GrpcController.java x: 76 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java x: 75 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcher.java x: 165 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherConfiguration.java x: 89 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java x: 114 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/ThroughputTracker.java x: 66 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java x: 396 lines of code y: 1 # changes uforwarder-core/src/main/resources/masterJobs.html x: 234 lines of code y: 1 # changes uforwarder-core/src/main/resources/masters.html x: 107 lines of code y: 1 # changes uforwarder-core/src/main/resources/workerJobs.html x: 228 lines of code y: 1 # changes uforwarder-core/src/main/resources/workers.html x: 123 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java x: 142 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingJob.java x: 56 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java x: 69 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/WindowedAggregator.java x: 85 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckManager.java x: 78 lines of code y: 1 # changes
8.0
# changes
  min: 1.0
  average: 1.65
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 8.0
0 1095.0
lines of code
min: 2.0 | average: 88.96 | 25th percentile: 20.0 | median: 48.0 | 75th percentile: 102.0 | max: 1095.0

Number of Contributors vs. Number of Changes: 291 points

uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 5 # contributors y: 5 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/DelayProcessManager.java x: 1 # contributors y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 4 # contributors y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 5 # contributors y: 8 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/DynamicConfiguration.java x: 3 # contributors y: 2 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 4 # contributors y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java x: 5 # contributors y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AsyncInflightLimiterAdapter.java x: 2 # contributors y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 5 # contributors y: 6 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java x: 3 # contributors y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 2 # contributors y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 2 # contributors y: 2 # changes
8.0
# changes
  min: 1.0
  average: 1.65
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 8.0
0 5.0
# contributors
min: 1.0 | average: 2.46 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 5.0

Number of Contributors vs. File Size: 291 points

uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 5 # contributors y: 1095 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/DelayProcessManager.java x: 1 # contributors y: 38 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java x: 1 # contributors y: 158 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 4 # contributors y: 86 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java x: 4 # contributors y: 89 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java x: 4 # contributors y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java x: 4 # contributors y: 110 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java x: 4 # contributors y: 123 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 4 # contributors y: 254 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java x: 4 # contributors y: 102 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 5 # contributors y: 259 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java x: 5 # contributors y: 539 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java x: 4 # contributors y: 68 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/DynamicConfiguration.java x: 3 # contributors y: 43 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/PodIsolationStatus.java x: 1 # contributors y: 5 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 5 # contributors y: 49 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java x: 5 # contributors y: 169 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredLogging.java x: 4 # contributors y: 224 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/JobGroupAndWorkerPodifier.java x: 1 # contributors y: 101 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 4 # contributors y: 54 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java x: 3 # contributors y: 417 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java x: 3 # contributors y: 51 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/ConsoleMatcher.java x: 1 # contributors y: 63 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/UForwarderAppType.java x: 3 # contributors y: 6 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java x: 5 # contributors y: 143 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/CompositeFilter.java x: 1 # contributors y: 39 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/Filter.java x: 1 # contributors y: 11 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/OriginalClusterFilter.java x: 1 # contributors y: 22 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 5 # contributors y: 1077 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java x: 4 # contributors y: 45 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactory.java x: 3 # contributors y: 46 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/SerializerType.java x: 3 # contributors y: 29 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/StoreAutoConfiguration.java x: 3 # contributors y: 167 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TypeRegistryAutoConfiguration.java x: 1 # contributors y: 13 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/Rebalancer.java x: 4 # contributors y: 162 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 5 # contributors y: 337 lines of code uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 4 # contributors y: 264 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java x: 4 # contributors y: 433 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AbstractInflightLimiter.java x: 4 # contributors y: 49 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AdaptiveInflightLimiter.java x: 4 # contributors y: 75 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AsyncInflightLimiterAdapter.java x: 2 # contributors y: 212 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java x: 3 # contributors y: 113 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilter.java x: 3 # contributors y: 20 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilterChain.java x: 3 # contributors y: 62 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java x: 3 # contributors y: 100 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/ShutdownableThread.java x: 3 # contributors y: 96 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 5 # contributors y: 248 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 4 # contributors y: 323 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/PodAwareRebalanceGroup.java x: 1 # contributors y: 33 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java x: 4 # contributors y: 179 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 5 # contributors y: 120 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 4 # contributors y: 352 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java x: 3 # contributors y: 200 lines of code idl/src/main/proto/data/kafka/data-transfer/job.proto x: 5 # contributors y: 410 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 5 # contributors y: 166 lines of code uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/MetadataAdapter.java x: 3 # contributors y: 80 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java x: 4 # contributors y: 212 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/VegasAdaptiveInflightLimiter.java x: 3 # contributors y: 54 lines of code uforwarder/src/main/resources/application-uforwarder-controller.yaml x: 5 # contributors y: 96 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/PodUtils.java x: 1 # contributors y: 19 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/MasterManagementAutoConfiguration.java x: 1 # contributors y: 52 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 4 # contributors y: 359 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 4 # contributors y: 24 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 4 # contributors y: 73 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetector.java x: 3 # contributors y: 69 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java x: 3 # contributors y: 25 lines of code idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 3 # contributors y: 93 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 3 # contributors y: 402 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 3 # contributors y: 129 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 3 # contributors y: 149 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 3 # contributors y: 409 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 2 # contributors y: 60 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 3 # contributors y: 10 lines of code uforwarder-core/src/main/resources/workerJobStatus.html x: 3 # contributors y: 197 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 2 # contributors y: 31 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 3 # contributors y: 33 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java x: 3 # contributors y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 3 # contributors y: 146 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 3 # contributors y: 236 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 3 # contributors y: 289 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/AdminClient.java x: 2 # contributors y: 75 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java x: 3 # contributors y: 192 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermit.java x: 2 # contributors y: 30 lines of code uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainer.java x: 3 # contributors y: 16 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumer.java x: 2 # contributors y: 12 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java x: 2 # contributors y: 94 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java x: 2 # contributors y: 47 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java x: 2 # contributors y: 51 lines of code uforwarder-sample-consumer/src/main/resources/application.yaml x: 2 # contributors y: 5 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java x: 3 # contributors y: 453 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java x: 3 # contributors y: 58 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java x: 3 # contributors y: 248 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/Attribute.java x: 2 # contributors y: 25 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java x: 3 # contributors y: 258 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java x: 3 # contributors y: 208 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java x: 3 # contributors y: 222 lines of code fievel-common/src/main/java/com/uber/fievel/testing/base/FievelTestBase.java x: 2 # contributors y: 2 lines of code idl/src/main/proto/data/kafka/data-transfer/job_snapshot.proto x: 2 # contributors y: 16 lines of code idl/src/main/proto/data/kafka/data-transfer/master_admin_service.proto x: 2 # contributors y: 81 lines of code idl/src/main/proto/data/kafka/data-transfer/worker.proto x: 2 # contributors y: 41 lines of code idl/src/main/proto/data/kafka/messaging-consumer/dlq_metadata.proto x: 2 # contributors y: 35 lines of code idl/src/main/proto/data/kafka/messaging-consumer/offset_mapping.proto x: 2 # contributors y: 72 lines of code idl/src/main/proto/data/kafka/messaging-consumer/offsets.proto x: 2 # contributors y: 55 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java x: 2 # contributors y: 204 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/Placement.java x: 2 # contributors y: 18 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalarConfiguration.java x: 2 # contributors y: 146 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobThroughputMonitor.java x: 2 # contributors y: 104 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleState.java x: 2 # contributors y: 178 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleWindow.java x: 2 # contributors y: 102 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator/LeaderSelector.java x: 2 # contributors y: 186 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorWithOffsets.java x: 2 # contributors y: 64 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancingJobGroup.java x: 2 # contributors y: 134 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java x: 2 # contributors y: 231 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java x: 2 # contributors y: 326 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecorator.java x: 2 # contributors y: 130 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java x: 2 # contributors y: 87 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecorator.java x: 2 # contributors y: 98 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecorator.java x: 2 # contributors y: 241 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStore.java x: 2 # contributors y: 233 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcher.java x: 2 # contributors y: 165 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java x: 2 # contributors y: 114 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/ThroughputTracker.java x: 2 # contributors y: 66 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java x: 2 # contributors y: 396 lines of code uforwarder-core/src/main/resources/workerJobs.html x: 2 # contributors y: 228 lines of code uforwarder-core/src/main/resources/workers.html x: 2 # contributors y: 123 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java x: 2 # contributors y: 142 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/WindowedAggregator.java x: 2 # contributors y: 85 lines of code
1095.0
lines of code
  min: 2.0
  average: 88.96
  25th percentile: 20.0
  median: 48.0
  75th percentile: 102.0
  max: 1095.0
0 5.0
# contributors
min: 1.0 | average: 2.46 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 5.0