uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java [181:218]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            });
  }

  private AddJobGroupRequest getAddJobGroupRequest(
      String topicName,
      String consumerGroupName,
      String procedureName,
      String dlqTopicName,
      List<String> retryTopicNames) {
    RetryConfig.Builder retryConfigBuilder = RetryConfig.newBuilder();
    if (!retryTopicNames.isEmpty()) {
      retryConfigBuilder.setRetryEnabled(true);
      retryTopicNames.forEach(
          r ->
              retryConfigBuilder.addRetryQueues(
                  RetryQueue.newBuilder()
                      .setProcessingDelayMs(0)
                      .setMaxRetryCount(2)
                      .setRetryCluster(TEST_CLUSTER_NAME)
                      .setRetryQueueTopic(r)
                      .build()));
    }

    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/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java [349:386]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            });
  }

  private AddJobGroupRequest getAddJobGroupRequest(
      String topicName,
      String consumerGroupName,
      String procedureName,
      String dlqTopicName,
      List<String> retryTopicNames) {
    RetryConfig.Builder retryConfigBuilder = RetryConfig.newBuilder();
    if (!retryTopicNames.isEmpty()) {
      retryConfigBuilder.setRetryEnabled(true);
      retryTopicNames.forEach(
          r ->
              retryConfigBuilder.addRetryQueues(
                  RetryQueue.newBuilder()
                      .setProcessingDelayMs(0)
                      .setMaxRetryCount(2)
                      .setRetryCluster(TEST_CLUSTER_NAME)
                      .setRetryQueueTopic(r)
                      .build()));
    }

    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()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -