uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java [204:218]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    return AddJobGroupRequest.newBuilder()
        .setJobGroup(
            JobGroup.newBuilder()
                .setType(JobType.JOB_TYPE_KAFKA_CONSUMER_TO_RPC_DISPATCHER)
                .setJobGroupId(
                    String.join(
                        JOB_GROUP_ID_DELIMITER, topicName, TEST_CLUSTER_NAME, consumerGroupName))
                .setKafkaConsumerTaskGroup(
                    KafkaConsumerTaskGroup.newBuilder()
                        .setCluster(TEST_CLUSTER_NAME)
                        .setTopic(topicName)
                        .setConsumerGroup(consumerGroupName)
                        .build())
                .setRpcDispatcherTaskGroup(
                    RpcDispatcherTaskGroup.newBuilder()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java [45:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    return AddJobGroupRequest.newBuilder()
        .setJobGroup(
            JobGroup.newBuilder()
                .setType(JobType.JOB_TYPE_KAFKA_CONSUMER_TO_RPC_DISPATCHER)
                .setJobGroupId(
                    String.join(
                        JOB_GROUP_ID_DELIMITER, topicName, TEST_CLUSTER_NAME, consumerGroupName))
                .setKafkaConsumerTaskGroup(
                    KafkaConsumerTaskGroup.newBuilder()
                        .setCluster(TEST_CLUSTER_NAME)
                        .setTopic(topicName)
                        .setConsumerGroup(consumerGroupName)
                        .build())
                .setRpcDispatcherTaskGroup(
                    RpcDispatcherTaskGroup.newBuilder()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -