Path	Lines of Code
instrumentation/src/test/java/com/uber/data/kafka/instrumentation/BiConsumerConverterTest.java	21
instrumentation/src/test/java/com/uber/data/kafka/instrumentation/DirectSupplierTest.java	20
instrumentation/src/test/java/com/uber/data/kafka/instrumentation/InstrumentTest.java	262
instrumentation/src/test/java/com/uber/data/kafka/instrumentation/InstrumentationTest.java	543
instrumentation/src/test/java/com/uber/data/kafka/instrumentation/NoopClosableTest.java	15
instrumentation/src/test/java/com/uber/data/kafka/instrumentation/TagsTest.java	22
uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/BytesMarshallerTest.java	21
uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerBytesServerMethodDefinitionTest.java	18
uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerMetadataTest.java	105
uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponseTest.java	102
uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/KafkaServerMethodDefinitionTest.java	20
uforwarder-client/src/test/java/com/uber/data/kafka/consumerproxy/client/grpc/MetadataAdapterTest.java	79
uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainerTest.java	33
uforwarder-container/src/test/java/com/uber/data/kafka/consumerproxy/container/UForwarderWorkerContainerTest.java	26
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/AdminClientTest.java	93
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/ControllerClientStaticResolverTest.java	19
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/CoreInfraTest.java	14
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/DynamicConfigurationTest.java	19
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/JobUtilsTest.java	484
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactoryTest.java	62
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcherTest.java	234
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/MetricsConfigurationTest.java	22
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/NodeAutoConfigurationTest.java	25
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/NodeUtilsTest.java	21
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/PodUtilsTest.java	16
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/ProtoSerializationFactoryTest.java	37
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/RoutingUtilsTest.java	16
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/RunningLifecycleTest.java	18
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/StructuredLoggingTest.java	30
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/StructuredTagsTest.java	18
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/TimestampUtilsTest.java	22
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/VersionedProtoTest.java	39
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/ZKStringSerializerTest.java	27
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/common/utils/ShutdownableThreadTest.java	56
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalarConfigurationTest.java	137
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalarTest.java	322
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobThroughputMonitorTest.java	97
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleStateTest.java	156
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleWindowTest.java	84
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/JobGroupStoreConfigurationTest.java	22
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/JobStatusStoreConfigurationTest.java	32
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/JobStoreConfigurationTest.java	25
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/StoreConfigurationTest.java	51
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/WorkerStoreConfigurationTest.java	32
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfigurationTest.java	23
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/coordinator/LeaderSelectorTest.java	198
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreatorTest.java	271
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorAutoConfiguration2.java	11
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorAutoConfigurationTest.java	43
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorTest.java	39
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorWithOffsetsTest.java	57
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/creator/StreamingJobCreatorTest.java	31
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/manager/JobManagerTest.java	430
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/manager/ManagerAutoConfigurationTest.java	43
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/manager/WorkerManagerTest.java	45
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/manager/WorkerStoreAutoConfiguration.java	14
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/JobPodPlacementProviderTest.java	25
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancerAutoConfiguration2.java	11
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancerAutoConfigurationTest.java	43
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancerTest.java	602
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancingJobGroupTest.java	111
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rebalancer/ShadowRebalancerDelegateTest.java	116
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rpc/CommandListBuilderTest.java	153
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminServiceTest.java	292
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerServiceTest.java	413
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/rpc/RpcAutoConfigurationTest.java	46
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecoratorTest.java	89
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecoratorWithTTLTest.java	130
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/IdExtractorTest.java	30
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/JobGroupIdProviderTest.java	47
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/JobStoreTest.java	63
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/LocalSequencerTest.java	23
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStoreTest.java	85
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecoratorTest.java	178
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/MockAsyncStage.java	11
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/SerializerTypeTest.java	16
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/StoreAutoConfigurationTest.java	106
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecoratorTest.java	270
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/TypeRegistryAutoConfigurationTest.java	11
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/ZKSequencerTest.java	50
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStoreIntegrationTest.java	100
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStoreTest.java	333
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/AbstractHtmlTest.java	16
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/JobStatusJsonTest.java	30
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/JobsJsonTest.java	39
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/ManagementServerConfigurationTest.java	21
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/MasterManagementAutoConfigurationTest.java	59
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/MastersHtmlTest.java	10
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/MastersJsonTest.java	16
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/NavJsonTest.java	10
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/NodeUrlResolverTest.java	13
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/WorkerManagementAutoConfigurationTest.java	49
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/WorkersHtmlTest.java	10
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/management/WorkersJsonTest.java	33
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/utils/NodeConfigurationUtilsTest.java	23
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/utils/UForwarderSpringJUnit4ClassRunner.java	8
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/ChainableTest.java	17
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/ConfigurableTest.java	10
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/ControllableTest.java	39
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/PipelineStateManagerTest.java	49
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/SinkTest.java	32
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecordTest.java	248
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerAutoConfigurationTest.java	68
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerClientFactoryTest.java	56
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerClientTest.java	60
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/GrpcControllerTest.java	43
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/LeaseTest.java	18
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/controller/StateMachineTest.java	764
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherConfigurationTest.java	26
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherFactoryAutoConfigurationTest.java	98
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherFactoryTest.java	16
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcherTest.java	122
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest.java	847
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest1.java	400
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest2.java	144
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThreadTest3.java	375
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/CheckpointInfoTest.java	31
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTrackerTest.java	116
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManagerTest.java	98
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManagerTest.java	192
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfigurationTest.java	97
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherTest.java	56
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThreadTest.java	88
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/ThroughputTrackerTest.java	50
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManagerTest.java	352
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactoryTest.java	25
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManagerAutoConfigurationTest.java	28
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManagerTest.java	361
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineMetricPublisherTest.java	19
uforwarder-core/src/test/java/com/uber/data/kafka/datatransfer/worker/processors/TranslatingPushPushProcessorTest.java	27
uforwarder-core/src/test/resources/base.yaml	78
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/UForwarderTest.java	53
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/common/ApplicationReadyListenerTest.java	16
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/common/StructuredLoggingTest.java	31
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/common/StructuredTagsTest.java	32
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/BatchRebalancerConfigurationTest.java	24
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfigurationTest.java	23
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/KafkaAdminClientConfigurationTest.java	55
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/KafkaAdminClientConfigurationTest1.java	46
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/NoopTracerAutoConfigurationTest.java	22
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfigurationTest.java	27
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/RebalanceConfigurationTest.java	22
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/SchedulerConfigurationTest.java	18
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/config/StreamingRebalancerConfigurationTest.java	27
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/GrpcServerRunnerTest.java	41
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactoryTest.java	88
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/config/CoordinatorAutoConfigurationTest.java	45
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancerTest.java	931
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancerTest.java	304
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancerTest.java	188
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/JobGroupAndWorkerPodifierTest.java	139
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancerTest.java	1372
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/ShadowRebalancerDelegateImplTest.java	166
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/StreamingRpcUriRebalancerTest.java	94
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/management/WorkerStubsJsonTest.java	30
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/utils/NodeConfigurationUtilsTest.java	23
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/utils/RetryUtilsTest.java	139
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/utils/UForwarderSpringJUnit4ClassRunner.java	8
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImplTest.java	156
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/PipelineImplTest.java	166
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactoryTest.java	71
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImplTest.java	273
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessageTest.java	486
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponseTest.java	43
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/DedupHeaderInterceptorTest.java	102
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcCallOptionsExtractorTest.java	3
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherCancelTest.java	179
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherTest.java	427
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilterChainTest.java	69
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPoolTest.java	160
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequestTest.java	397
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtilsTest.java	46
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcherTest.java	318
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactoryTest.java	124
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcherTest.java	319
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcherTest.java	231
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/filter/CompositeFilterTest.java	56
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/filter/OriginalClusterFilterTest.java	41
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/AdaptiveInflightLimiterTest.java	159
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/AsyncInflightLimiterAdapterTest.java	164
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/BootstrapLongFixedInflightLimiterTest.java	74
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiterTest.java	187
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/VegasAdaptiveInflightLimiterTest.java	24
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/VegasAdaptiveInlightLimiterTest.java	13
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/limiter/WindowedAggregatorTest.java	69
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/AckManagerTest.java	111
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueueTest.java	431
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManagerTest.java	278
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/CancelResultTest.java	19
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffsetTest.java	42
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManagerTest.java	61
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetectorTest.java	83
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueueTest.java	552
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManagerTest.java	183
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStubTest.java	227
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermitTest.java	35
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactoryTest.java	45
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImplTest.java	1860
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessageTest.java	847
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorTestBase.java	178
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiterTest.java	280
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/StubManagerTest.java	84
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffsetTest.java	46
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManagerTest.java	440
uforwarder/src/test/java/com/uber/data/kafka/consumerproxy/worker/processor/WindowedTokenLimiterTest.java	55
uforwarder/src/test/resources/base.yaml	110
uforwarder/src/test/resources/batch-job.yaml	9
uforwarder/src/test/resources/data/processing.py	23
uforwarder/src/test/resources/logback-test.xml	20
uforwarder/src/test/resources/static-mode-offset-committer.yaml	7
uforwarder/src/test/resources/static-mode-offset-fetcher.yaml	9
uforwarder/src/test/resources/streaming-job-auto-config.yaml	7
uforwarder/src/test/resources/streaming-job.yaml	13