uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java [78:93]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @ClassRule public static final Network network = Network.newNetwork();

  @ClassRule
  public static final EnvironmentVariables environmentVariables = new EnvironmentVariables();

  @BeforeClass
  public static void setup() throws Exception {
    mockConsumerServer =
        MockConsumerServiceStarter.startTestService(
            TEST_GROUP_NAME,
            TEST_SERVICE_GRPC_PORT,
            ImmutableList.of(
                // Simple consumer
                ConsumerBytesServerMethodDefinition.of(
                    TEST_GROUP_NAME,
                    TEST_TOPIC_NAME,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java [92:107]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @ClassRule public static final Network network = Network.newNetwork();

  @ClassRule
  public static final EnvironmentVariables environmentVariables = new EnvironmentVariables();

  @BeforeClass
  public static void setup() throws Exception {
    mockConsumerServer =
        MockConsumerServiceStarter.startTestService(
            TEST_GROUP_NAME,
            TEST_SERVICE_GRPC_PORT,
            ImmutableList.of(
                // Simple consumer
                ConsumerBytesServerMethodDefinition.of(
                    TEST_GROUP_NAME,
                    TEST_TOPIC_NAME,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -