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 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)
0% | 0% | 98% | 1% | <1%
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)
0% | 0% | 49% | 18% | 31%
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
java0% | 0% | 97% | 1% | <1%
proto0% | 0% | 100% | 0% | 0%
html0% | 0% | 100% | 0% | 0%
yaml0% | 0% | 96% | 3% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java0% | 0% | 49% | 19% | 30%
html0% | 0% | 77% | 0% | 22%
proto0% | 0% | 36% | 0% | 63%
yaml0% | 0% | 33% | 66% | 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-core0% | 0% | 98% | <1% | <1%
uforwarder0% | 0% | 98% | 1% | 0%
idl0% | 0% | 100% | 0% | 0%
instrumentation0% | 0% | 100% | 0% | 0%
uforwarder-container0% | 0% | 100% | 0% | 0%
uforwarder-client0% | 0% | 100% | 0% | 0%
fievel-common0% | 0% | 100% | 0% | 0%
uforwarder-sample-consumer0% | 0% | 0% | 100% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
uforwarder-core0% | 0% | 68% | 10% | 21%
uforwarder0% | 0% | 33% | 26% | 40%
idl0% | 0% | 36% | 0% | 63%
instrumentation0% | 0% | 41% | 0% | 58%
uforwarder-client0% | 0% | 100% | 0% | 0%
uforwarder-container0% | 0% | 12% | 87% | 0%
uforwarder-sample-consumer0% | 0% | 0% | 100% | 0%
fievel-common0% | 0% | 0% | 100% | 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
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# unitscreatedlast modified# changes
(days)
# contributorsfirst
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# unitscreatedlast modified# changes
(days)
# contributorsfirst
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# unitscreatedlast modified# changes
(days)
# contributorsfirst
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...