uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java [36:49]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      String threadName,
      KafkaFetcherConfiguration config,
      CheckpointManager checkpointManager,
      ThroughputTracker throughputTracker,
      Consumer<byte[], byte[]> kafkaConsumer,
      CoreInfra infra) {
    super(
        threadName,
        config,
        checkpointManager,
        throughputTracker,
        new InflightMessageTracker(),
        kafkaConsumer,
        infra,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java [40:53]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      String threadName,
      KafkaFetcherConfiguration config,
      CheckpointManager checkpointManager,
      ThroughputTracker throughputTracker,
      Consumer<byte[], byte[]> kafkaConsumer,
      CoreInfra infra) {
    super(
        threadName,
        config,
        checkpointManager,
        throughputTracker,
        new InflightMessageTracker(),
        kafkaConsumer,
        infra,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -