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 291 files with 25,887 lines of code in files.
    • 273 files that are 366+ days old (25,154 lines of code)
    • 5 files that are 181-365 days old (156 lines of code)
    • 13 files that are 91-180 days old (577 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)
97% | <1% | 2% | 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 291 files with 25,887 lines of code in files.
    • 215 files have been last changed 366+ days ago (14,368 lines of code)
    • 5 files have been last changed 181-365 days ago (156 lines of code)
    • 71 files have been last changed 91-180 days ago (11,363 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)
55% | <1% | 43% | 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, proto, json, yaml, 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
java96% | <1% | 2% | 0% | 0%
proto100% | 0% | 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
java54% | <1% | 44% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
proto48% | 0% | 51% | 0% | 0%
yaml3% | 0% | 96% | 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-core96% | 1% | 2% | 0% | 0%
uforwarder97% | 0% | 2% | 0% | 0%
idl100% | 0% | 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-core67% | 1% | 30% | 0% | 0%
uforwarder40% | 0% | 59% | 0% | 0%
instrumentation100% | 0% | 0% | 0% | 0%
idl48% | 0% | 51% | 0% | 0%
uforwarder-sample-consumer100% | 0% | 0% | 0% | 0%
uforwarder-client71% | 0% | 28% | 0% | 0%
uforwarder-container17% | 0% | 82% | 0% | 0%
fievel-common100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1095 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1077 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 539 24 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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...
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 433 27 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
 410 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
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
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 359 18 2023-12-01 2024-04-24 4 4 43356004+yangy0000@users.no... yayang@uber.com
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
 337 14 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
 323 25 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 264 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 259 10 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
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
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 224 51 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
 222 19 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
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
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 178 - 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 169 8 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
StoreAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 167 10 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
DispatcherMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 166 7 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
 162 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
WorkerManagementConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 18 3 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
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KafkaDelayProcessManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 158 6 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
JobGroupAndWorkerPodifier.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 101 3 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
ConsoleMatcher.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 63 7 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
CompositeFilter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter
 39 4 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
DelayProcessManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 38 5 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
JobPodPlacementProvider.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 38 5 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
ApplicationReadyListener.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 37 6 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
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 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
Filter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter
 11 - 2024-12-06 2024-12-06 1 1 chenhaifeng88888@gmail.com chenhaifeng88888@gmail.com
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
 52 7 2024-05-18 2024-05-18 1 1 yayang@uber.com yayang@uber.com
WorkerManagementAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 40 5 2024-05-18 2024-05-18 1 1 yayang@uber.com yayang@uber.com
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 2024-05-18 1 1 yayang@uber.com yayang@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
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
 25 1 2024-01-08 2024-04-08 3 3 67832317+ericzhifengchen@us... 67832317+ericzhifengchen@us...
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
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1095 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1077 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 539 24 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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...
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 433 27 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
 410 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
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
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 359 18 2023-12-01 2024-04-24 4 4 43356004+yangy0000@users.no... yayang@uber.com
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
 337 14 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
 323 25 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.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
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 264 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 259 10 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1095 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1077 31 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 539 24 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 433 27 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
 410 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 352 27 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 337 14 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 323 25 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 264 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 259 10 2023-12-01 2024-12-06 8 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
JobManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager
 254 8 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 224 51 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 222 19 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
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
AutoScalar.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 200 14 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
TracedConsumerRecord.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 179 9 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 178 - 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 169 8 2023-12-01 2024-12-06 5 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
StoreAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 167 10 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
DispatcherMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 166 7 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 162 5 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
UForwarderWorkerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 143 6 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RetryTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 123 4 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 120 15 2023-12-01 2024-12-06 6 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
LongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 113 11 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
OriginalTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 110 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 107 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
BootstrapLongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 106 11 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
RebalancerConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 102 24 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
MockConsumerServiceStarter.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 100 5 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
application-uforwarder-controller.yaml
in uforwarder/src/main/resources
 96 - 2023-12-01 2024-12-06 4 5 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ShutdownableThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils
 96 12 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
DlqTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 89 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
WorkersJson.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 86 1 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
KafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 86 2 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
MetadataAdapter.java
in uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc
 80 11 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
AdaptiveInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 75 6 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ProcessorConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 68 18 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
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
GrpcFilterChain.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 62 8 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
ControllerAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 56 3 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
InflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 55 6 2023-12-01 2024-12-06 4 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
application-uforwarder-worker.yaml
in uforwarder/src/main/resources
 55 - 2023-12-01 2024-12-06 3 4 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com
VegasAdaptiveInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 54 7 2023-12-01 2024-12-06 2 3 43356004+yangy0000@users.no... chenhaifeng88888@gmail.com