uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java [295:308]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        value,
        kafkaHeaders,
        logicalGroup,
        logicalTopic,
        logicalPartition,
        logicalOffset,
        stub,
        physicalTopic,
        physicalCluster,
        physicalPartition,
        physicalOffset,
        retryCount.get(),
        dispatchAttempt.get(),
        timeoutCount.get());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java [327:340]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        value,
        kafkaHeaders,
        logicalGroup,
        logicalTopic,
        logicalPartition,
        logicalOffset,
        stub,
        physicalTopic,
        physicalCluster,
        physicalPartition,
        physicalOffset,
        retryCount.get(),
        dispatchAttempt.get(),
        timeoutCount.get());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -