uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java [286:297]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
          StructuredLogging.jobId(job.getJobId()),
          StructuredLogging.kafkaTopic(task.getTopic()),
          StructuredLogging.kafkaPartition(task.getPartition()),
          StructuredLogging.kafkaCluster(task.getCluster()),
          StructuredLogging.kafkaGroup(task.getConsumerGroup()));
      scope
          .tagged(
              StructuredTags.builder()
                  .setKafkaGroup(job.getKafkaConsumerTask().getConsumerGroup())
                  .setKafkaTopic(job.getKafkaConsumerTask().getTopic())
                  .setKafkaPartition(job.getKafkaConsumerTask().getPartition())
                  .build())
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java [313:324]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
          StructuredLogging.jobId(job.getJobId()),
          StructuredLogging.kafkaTopic(task.getTopic()),
          StructuredLogging.kafkaPartition(task.getPartition()),
          StructuredLogging.kafkaCluster(task.getCluster()),
          StructuredLogging.kafkaGroup(task.getConsumerGroup()));
      scope
          .tagged(
              StructuredTags.builder()
                  .setKafkaGroup(job.getKafkaConsumerTask().getConsumerGroup())
                  .setKafkaTopic(job.getKafkaConsumerTask().getTopic())
                  .setKafkaPartition(job.getKafkaConsumerTask().getPartition())
                  .build())
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -