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