Uber / uForwarderFile 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

Number of files: 272
Daily file updates (only one update per file and date counted): 631
First update: 2023-12-01
Latest update: 2024-03-13
Days between first and latest update: 104 (14 weeks, estimated 70 working days)
Active days (at least one file change): 9
Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 272 files with 24,384 lines of code in files.

0 files that are 366+ days old (0 lines of code)
0 files that are 181-365 days old (0 lines of code)
260 files that are 91-180 days old (23,909 lines of code)
11 files that are 31-90 days old (415 lines of code)
1 files that are 1-30 days old (60 lines of code)

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 272 files with 24,384 lines of code in files.

0 files have been last changed 366+ days ago (0 lines of code)
0 files have been last changed 181-365 days ago (0 lines of code)
197 files have been last changed 91-180 days ago (12,134 lines of code)
36 files have been last changed 31-90 days ago (4,491 lines of code)
39 files have been last changed 1-30 days ago (7,759 lines of code)

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, proto, json, yaml, html, sh, md, yml, 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

File Freshness Distribution per Extension

Days since last update

366+

181-365

91-180

31-90

1-30

File Change History per Logical Decomposition

primary

primary (file age distribution)

Days since first update

366+

181-365

91-180

31-90

1-30

primary (file freshness distribution)

Days since last update

366+

181-365

91-180

31-90

1-30

Oldest Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
ProcessorImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	1008	29	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
AbstractKafkaFetcherThread.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	946	29	2023-12-01	2024-03-06	2	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...
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
UforwarderIntegrationTests.java in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy	408	11	2023-12-01	2023-12-01	1	2	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
RpcJobColocatingRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	402	22	2023-12-01	2024-03-06	5	3	43356004+yangy0000@users.no...	chenz@uber.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
SimpleOutboundMessageLimiter.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	389	26	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
proto job.proto in idl/src/main/proto/data/kafka/data-transfer	382	-	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	356	18	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
ProcessorMessage.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	341	26	2023-12-01	2024-03-06	2	3	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
AbstractAckTrackingQueue.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	322	25	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
GrpcDispatcher.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	311	13	2023-12-01	2024-03-06	2	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
RebalancerCommon.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	276	10	2023-12-01	2024-03-06	5	3	43356004+yangy0000@users.no...	chenz@uber.com
UforwarderContainerIntegrationTests.java in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container	264	8	2023-12-01	2024-01-08	3	3	43356004+yangy0000@users.no...	67832317+ericzhifengchen@us...
BlockingQueueStubManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	258	15	2023-12-01	2024-01-08	2	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-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
ArrayAckTrackingQueue.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	248	15	2023-12-01	2024-01-08	2	3	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
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
KafkaPartitionExpansionWatcher.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	235	4	2023-12-01	2024-01-08	2	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
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
MessageAckStatusManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	222	15	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
JobUtils.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	219	19	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
StructuredLogging.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	214	48	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
GrpcManagedChannelPool.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	214	25	2023-12-01	2024-03-06	2	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	2023-12-01	1	2	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
AutoScalar.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	200	14	2023-12-01	2023-12-01	1	2	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
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
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
TracedConsumerRecord.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common	172	9	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	172	-	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
DispatcherMessage.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher	169	7	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
RetryTopicKafkaFetcher.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher	169	5	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
DispatcherImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher	168	6	2023-12-01	2024-01-26	2	3	43356004+yangy0000@users.no...	chenz@uber.com
BatchRpcUriRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	167	4	2023-12-01	2024-01-26	2	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
StoreAutoConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage	160	10	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	156	5	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
StateRegistering.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller	149	3	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com

Files Not Recently Changed (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
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
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
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
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
DataTransferMaster.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller	4	-	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
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
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
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
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
UForwarderAppType.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy	6	1	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
JobThroughputSink.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc	6	-	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
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
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
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
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
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
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
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
ScaleComputer.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	10	-	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
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
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
TimestampUtils.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	11	2	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
Scalar.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	11	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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
AbstractJobsJson.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management	16	2	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
OutboundMessageLimiter.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	18	-	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

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
InflightMessageTracker.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	60	9	2024-03-06	2024-03-06	1	2	67832317+ericzhifengchen@us...	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
AdminClient.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	75	13	2024-01-08	2024-01-26	2	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
Attribute.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	25	5	2024-01-08	2024-01-08	1	2	67832317+ericzhifengchen@us...	chenz@uber.com
SampleConsumerHandler.java in uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder	23	1	2024-01-08	2024-01-08	1	2	67832317+ericzhifengchen@us...	chenz@uber.com
AttributeKey.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	22	4	2024-01-08	2024-01-08	1	2	67832317+ericzhifengchen@us...	chenz@uber.com
SampleConsumer.java in uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder	12	1	2024-01-08	2024-01-08	1	2	67832317+ericzhifengchen@us...	chenz@uber.com
application.yaml in uforwarder-sample-consumer/src/main/resources	5	-	2024-01-08	2024-01-08	1	2	67832317+ericzhifengchen@us...	chenz@uber.com
ProcessorImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	1008	29	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
AbstractKafkaFetcherThread.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	946	29	2023-12-01	2024-03-06	2	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...
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
UforwarderIntegrationTests.java in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy	408	11	2023-12-01	2023-12-01	1	2	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
RpcJobColocatingRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	402	22	2023-12-01	2024-03-06	5	3	43356004+yangy0000@users.no...	chenz@uber.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
SimpleOutboundMessageLimiter.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	389	26	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
proto job.proto in idl/src/main/proto/data/kafka/data-transfer	382	-	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	356	18	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
ProcessorMessage.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	341	26	2023-12-01	2024-03-06	2	3	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
AbstractAckTrackingQueue.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	322	25	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
GrpcDispatcher.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	311	13	2023-12-01	2024-03-06	2	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
RebalancerCommon.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	276	10	2023-12-01	2024-03-06	5	3	43356004+yangy0000@users.no...	chenz@uber.com
UforwarderContainerIntegrationTests.java in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container	264	8	2023-12-01	2024-01-08	3	3	43356004+yangy0000@users.no...	67832317+ericzhifengchen@us...
BlockingQueueStubManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	258	15	2023-12-01	2024-01-08	2	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-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
ArrayAckTrackingQueue.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	248	15	2023-12-01	2024-01-08	2	3	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
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
KafkaPartitionExpansionWatcher.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	235	4	2023-12-01	2024-01-08	2	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
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
MessageAckStatusManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	222	15	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
JobUtils.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	219	19	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
StructuredLogging.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	214	48	2023-12-01	2023-12-01	1	2	43356004+yangy0000@users.no...	chenz@uber.com
GrpcManagedChannelPool.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	214	25	2023-12-01	2024-03-06	2	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	2023-12-01	1	2	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
AutoScalar.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	200	14	2023-12-01	2023-12-01	1	2	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
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

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
ProcessorImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	1008	29	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
AbstractKafkaFetcherThread.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	946	29	2023-12-01	2024-03-06	2	3	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
RpcJobColocatingRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	402	22	2023-12-01	2024-03-06	5	3	43356004+yangy0000@users.no...	chenz@uber.com
proto job.proto in idl/src/main/proto/data/kafka/data-transfer	382	-	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
ProcessorMessage.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	341	26	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
GrpcDispatcher.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	311	13	2023-12-01	2024-03-06	2	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
RebalancerCommon.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	276	10	2023-12-01	2024-03-06	5	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
GrpcManagedChannelPool.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	214	25	2023-12-01	2024-03-06	2	3	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
proto job_group.proto in idl/src/main/proto/data/kafka/data-transfer	172	-	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
DispatcherMessage.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher	169	7	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
RetryTopicKafkaFetcher.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher	169	5	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
StateRegistering.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller	149	3	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
PipelineImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker	146	15	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
State.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller	129	6	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
UForwarderWorkerFactory.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker	128	7	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
KafkaFetcherConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	127	17	2023-12-01	2024-03-06	4	3	43356004+yangy0000@users.no...	chenz@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
KafkaFetcherFactory.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher	106	3	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
CoreInfra.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	101	17	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
OriginalTopicKafkaFetcher.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher	95	3	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.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
DlqTopicKafkaFetcher.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher	87	3	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
KafkaFetcherThread.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	84	2	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
StructuredTags.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	69	16	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
ProcessorConfiguration.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config	68	18	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
InflightMessageTracker.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	60	9	2024-03-06	2024-03-06	1	2	67832317+ericzhifengchen@us...	chenz@uber.com
proto job_status.proto in idl/src/main/proto/data/kafka/data-transfer	53	-	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
CoreInfraAutoConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	49	5	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
StructuredTags.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common	48	9	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
StructuredLogging.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common	41	9	2023-12-01	2024-03-06	3	3	43356004+yangy0000@users.no...	chenz@uber.com
GrpcDispatcherConfiguration.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config	33	8	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	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
StructuredFields.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	22	-	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.com
PipelineFactory.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines	10	1	2023-12-01	2024-03-06	2	3	43356004+yangy0000@users.no...	chenz@uber.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
DispatcherImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher	168	6	2023-12-01	2024-01-26	2	3	43356004+yangy0000@users.no...	chenz@uber.com
BatchRpcUriRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	167	4	2023-12-01	2024-01-26	2	3	43356004+yangy0000@users.no...	chenz@uber.com
UForwarderControllerFactory.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller	149	7	2023-12-01	2024-01-26	3	3	43356004+yangy0000@users.no...	chenz@uber.com
AdminClient.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	75	13	2024-01-08	2024-01-26	2	2	67832317+ericzhifengchen@us...	chenz@uber.com
ProcessorFactory.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	41	2	2023-12-01	2024-01-26	2	3	43356004+yangy0000@users.no...	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
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...
KafkaPipelineStateManager.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines	356	18	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
AbstractAckTrackingQueue.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	322	25	2023-12-01	2024-01-08	2	3	43356004+yangy0000@users.no...	chenz@uber.com
UforwarderContainerIntegrationTests.java in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container	264	8	2023-12-01	2024-01-08	3	3	43356004+yangy0000@users.no...	67832317+ericzhifengchen@us...