Path	Lines of Code
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java	417
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/ConsoleMatcher.java	63
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/Constants.java	13
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/KafkaUtils.java	77
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java	100
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java	54
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java	51
uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java	52
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/UForwarder.java	48
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/UForwarderAppType.java	6
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/ApplicationReadyListener.java	37
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java	31
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java	49
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java	48
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java	33
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/KafkaAdminClientConfiguration.java	81
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/NoopTracerAutoConfiguration.java	18
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java	68
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java	102
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/SchedulerConfiguration.java	20
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/GrpcServerRunner.java	49
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java	169
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java	40
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java	453
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java	167
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java	142
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/JobGroupAndWorkerPodifier.java	101
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/PodAwareRebalanceGroup.java	33
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java	259
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingJob.java	56
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorker.java	36
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java	58
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java	539
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/ShadowRebalancerDelegateImpl.java	89
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/StreamingRpcUriRebalancer.java	39
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/management/WorkerStubsJson.java	47
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/utils/NodeConfigurationUtils.java	20
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/utils/RetryUtils.java	70
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java	107
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java	146
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java	143
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java	168
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java	166
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java	42
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/DedupHeaderInterceptor.java	62
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java	337
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherFactory.java	20
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilter.java	20
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilterChain.java	62
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java	248
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java	212
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcResponse.java	45
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java	69
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java	37
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java	89
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherAutoConfiguration.java	20
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java	107
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java	110
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java	123
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/CompositeFilter.java	39
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/Filter.java	11
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/OriginalClusterFilter.java	22
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AbstractInflightLimiter.java	49
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AdaptiveInflightLimiter.java	75
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AsyncInflightLimiterAdapter.java	212
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/BootstrapLongFixedInflightLimiter.java	106
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/InflightLimiter.java	55
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java	113
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/VegasAdaptiveInflightLimiter.java	54
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/WindowedAggregator.java	85
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java	323
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckManager.java	78
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java	55
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java	248
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/Attribute.java	25
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AttributeKey.java	22
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueue.java	25
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java	258
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/CancelResult.java	33
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java	34
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManager.java	95
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetector.java	69
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java	208
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java	222
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java	236
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermit.java	30
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/OutboundMessageLimiter.java	18
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java	45
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java	1077
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java	352
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java	433
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/StubManager.java	145
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TokenLimiter.java	17
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java	38
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java	289
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/WindowedTokenLimiter.java	71
uforwarder/src/main/resources/application-uforwarder-controller.yaml	96
uforwarder/src/main/resources/application-uforwarder-worker.yaml	55