uber / uForwarder
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 309 files with 27,490 lines of code in files.
    • 285 files that are 366+ days old (26,292 lines of code)
    • 24 files that are 181-365 days old (1,198 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
95% | 4% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 309 files with 27,490 lines of code in files.
    • 187 files have been last changed 366+ days ago (10,707 lines of code)
    • 122 files have been last changed 181-365 days ago (16,783 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
38% | 61% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, gradle, yaml, proto, json, html, sh, md, properties, gitignore, py, gitattributes, txt, bat, xml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java95% | 4% | 0% | 0% | 0%
proto96% | 3% | 0% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
yaml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java36% | 63% | 0% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
proto33% | 66% | 0% | 0% | 0%
yaml64% | 35% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
uforwarder-core92% | 7% | 0% | 0% | 0%
uforwarder98% | 1% | 0% | 0% | 0%
idl96% | 3% | 0% | 0% | 0%
instrumentation100% | 0% | 0% | 0% | 0%
uforwarder-container100% | 0% | 0% | 0% | 0%
uforwarder-client100% | 0% | 0% | 0% | 0%
uforwarder-sample-consumer100% | 0% | 0% | 0% | 0%
fievel-common100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
uforwarder-core35% | 64% | 0% | 0% | 0%
uforwarder38% | 61% | 0% | 0% | 0%
instrumentation100% | 0% | 0% | 0% | 0%
idl33% | 66% | 0% | 0% | 0%
uforwarder-sample-consumer100% | 0% | 0% | 0% | 0%
uforwarder-client50% | 50% | 0% | 0% | 0%
uforwarder-container17% | 82% | 0% | 0% | 0%
fievel-common100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1108 31 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1102 31 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 522 24 2023-12-01 2025-10-04 9 5 43356004+yangy0000@users.no... chenz@uber.com
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 483 33 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
AbstractRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 470 12 2023-12-01 2025-10-04 4 3 43356004+yangy0000@users.no... chenz@uber.com
UforwarderIntegrationTests.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy
 417 11 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
proto
job.proto
in idl/src/main/proto/data/kafka/data-transfer
 412 - 2023-12-01 2025-10-04 5 5 43356004+yangy0000@users.no... chenz@uber.com
StateWorking.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 409 4 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
Instrumentation.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 402 19 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 392 20 2023-12-01 2025-10-04 5 4 43356004+yangy0000@users.no... chenz@uber.com
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 389 14 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.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
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 348 14 2023-12-01 2025-10-04 5 5 43356004+yangy0000@users.no... chenz@uber.com
ControllerWorkerService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 327 9 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerAdminService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 321 9 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 318 25 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 303 21 2023-12-01 2025-10-04 2 2 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
AutoScalar.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 278 18 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 265 10 2023-12-01 2025-10-04 9 5 43356004+yangy0000@users.no... chenz@uber.com
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 265 8 2023-12-01 2025-10-04 5 4 43356004+yangy0000@users.no... chenz@uber.com
TTLDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 259 16 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
BlockingQueueStubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 258 15 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 253 4 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
JobManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager
 249 8 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
AutoScalarConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 240 53 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
BatchJobCreator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 238 9 2023-12-01 2025-10-04 4 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 2025-10-04 4 3 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
workerJobs.html
in uforwarder-core/src/main/resources
 228 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
DispatcherImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 227 8 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
ZKStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 227 14 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 222 19 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
MessageAckStatusManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 217 15 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.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
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 210 50 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
LinkedAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 208 13 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.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
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 201 - 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
workerJobStatus.html
in uforwarder-core/src/main/resources
 197 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 186 8 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
LeaderSelector.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator
 184 10 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.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
BatchRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 168 4 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.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
StoreAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 166 10 2023-12-01 2025-10-04 3 3 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
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 158 5 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
UForwarderWorkerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 152 7 2023-12-01 2025-10-04 5 5 43356004+yangy0000@users.no... chenz@uber.com
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DataTransferWorker.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker
 4 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Chainable.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 4 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
MetricSource.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 4 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Configurable.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 4 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Pipeline.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 5 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
IdProvider.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 5 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ThrowingRunnable.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 5 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
TriConsumer.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 5 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ThrowingBiConsumer.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 5 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ThrowingSupplier.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 5 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
SeekStartOffsetOption.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 7 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobStoreConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config
 7 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
HostResolver.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 7 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Mode.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 8 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ManagedChannelFactory.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 8 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
WorkersHtml.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 8 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobsHtml.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 8 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
MastersHtml.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 8 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
NoopClosable.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 9 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobGroupStoreConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config
 11 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ReadStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 11 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
NonRetriableException.java
in uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc
 11 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
RetriableException.java
in uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc
 11 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
UForwarderWorkerContainer.java
in uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container
 12 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
PipelineMetricPublisher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 12 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
RunningLifecycle.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 12 3 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaClusterResolver.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 12 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ManagementServerConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 12 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Tags.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 12 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Constants.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 13 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaDispatcherFactory.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 14 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobCreatorAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 14 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
RebalancerAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 14 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
NodeUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 14 3 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
CheckpointManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 15 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
DirectSupplier.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 15 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
BiConsumerConverter.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 15 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobCreator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 16 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Utils.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 16 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
proto
job_snapshot.proto
in idl/src/main/proto/data/kafka/data-transfer
 16 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
TokenLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 17 4 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ShadowRebalancerDelegate.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 18 5 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Placement.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 18 2 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
NoopTracerAutoConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 18 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Sink.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 19 4 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
StaticResolver.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 19 3 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AbstractHtml.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 19 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
IdExtractor.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 20 5 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobGroupIdProvider.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 20 5 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
TestUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 20 3 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
LatencyTracker.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 140 17 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
PipelineLoadManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 124 11 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
JobWorkloadMonitor.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 107 8 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
PipelineHealthManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 107 10 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ReactiveScaleWindowManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 105 6 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ScalePredictionUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 70 6 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ThreadRegister.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 67 6 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
PipelineHealthState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 62 7 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ReactiveScaleWindowCalculator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 61 3 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
proto
auto_scalar.proto
in idl/src/main/proto/data/kafka/data-transfer
 48 - 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
LingerSampler.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 48 4 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ScaleStatusStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 40 5 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
CpuUsageMeter.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 31 5 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
PipelineLoadTracker.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 31 4 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
PipelineHealthIssue.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 29 4 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ScaleWindowManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 24 5 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ScalePrediction.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 23 5 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ScalarSnapshotJson.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 22 2 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
KafkaPipelineIssue.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 18 1 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
Workload.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 15 3 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
JobPodAssigner.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 10 2 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
JobWorkloadSink.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 6 - 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ScaleConverterMode.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 5 - 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
ScaleConverter.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 5 - 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
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
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
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
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
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
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
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 2025-10-04 2 2 chenhaifeng88888@gmail.com chenz@uber.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
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
MasterManagementAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 63 8 2024-05-18 2025-10-04 2 2 yayang@uber.com chenz@uber.com
WorkerManagementAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 46 5 2024-05-18 2025-10-04 2 2 yayang@uber.com chenz@uber.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
NodeConfigurationUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/utils
 20 2 2024-05-18 2025-10-04 2 2 yayang@uber.com chenz@uber.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
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
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
AdminClient.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 72 13 2024-01-08 2025-10-04 3 2 67832317+ericzhifengchen@us... chenz@uber.com
Utils.java
in uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder
 51 2 2024-01-08 2024-01-08 1 2 67832317+ericzhifengchen@us... chenz@uber.com
SampleConsumerProducer.java
in uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder
 47 4 2024-01-08 2024-01-08 1 2 67832317+ericzhifengchen@us... chenz@uber.com
MetricsUtils.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 31 3 2024-01-08 2024-03-06 2 2 67832317+ericzhifengchen@us... chenz@uber.com
NestedPermit.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 30 1 2024-01-08 2024-01-26 2 2 67832317+ericzhifengchen@us... chenz@uber.com
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...
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1108 31 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1102 31 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 522 24 2023-12-01 2025-10-04 9 5 43356004+yangy0000@users.no... chenz@uber.com
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 483 33 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
AbstractRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 470 12 2023-12-01 2025-10-04 4 3 43356004+yangy0000@users.no... chenz@uber.com
proto
job.proto
in idl/src/main/proto/data/kafka/data-transfer
 412 - 2023-12-01 2025-10-04 5 5 43356004+yangy0000@users.no... chenz@uber.com
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 392 20 2023-12-01 2025-10-04 5 4 43356004+yangy0000@users.no... chenz@uber.com
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 389 14 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 348 14 2023-12-01 2025-10-04 5 5 43356004+yangy0000@users.no... chenz@uber.com
ControllerWorkerService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 327 9 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerAdminService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 321 9 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 318 25 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 303 21 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
AutoScalar.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 278 18 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 265 10 2023-12-01 2025-10-04 9 5 43356004+yangy0000@users.no... chenz@uber.com
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 265 8 2023-12-01 2025-10-04 5 4 43356004+yangy0000@users.no... chenz@uber.com
TTLDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 259 16 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
BlockingQueueStubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 258 15 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 253 4 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
JobManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager
 249 8 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
AutoScalarConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 240 53 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
BatchJobCreator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 238 9 2023-12-01 2025-10-04 4 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 2025-10-04 4 3 43356004+yangy0000@users.no... chenz@uber.com
DispatcherImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 227 8 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
ZKStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 227 14 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 222 19 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
MessageAckStatusManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 217 15 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 210 50 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 201 - 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 186 8 2023-12-01 2025-10-04 6 5 43356004+yangy0000@users.no... chenz@uber.com
LeaderSelector.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator
 184 10 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
BatchRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 168 4 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
StoreAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 166 10 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 158 5 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
UForwarderWorkerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 152 7 2023-12-01 2025-10-04 5 5 43356004+yangy0000@users.no... chenz@uber.com
PipelineImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 147 15 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancingJobGroup.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 145 14 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
StubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 143 15 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
LatencyTracker.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 140 17 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
HibernatingJobRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 134 6 2023-12-01 2025-10-04 2 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 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
PipelineFactoryImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 128 2 2023-12-01 2025-10-04 4 3 43356004+yangy0000@users.no... chenz@uber.com
CoreInfra.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 125 21 2023-12-01 2025-10-04 3 3 43356004+yangy0000@users.no... chenz@uber.com
PipelineLoadManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 124 11 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com
RetryTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 121 4 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
ScaleWindow.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 119 13 2023-12-01 2025-10-04 2 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaFetcherFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 110 3 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
OriginalTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 108 3 2023-12-01 2025-10-04 4 4 43356004+yangy0000@users.no... chenz@uber.com
JobWorkloadMonitor.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 107 8 2025-10-04 2025-10-04 1 1 chenz@uber.com chenz@uber.com