Неизвестный тестовый классMethod выполняется при развертывании кода в gitlab

Question

Я пытаюсь развернуть свой код в gitlab.

У него есть класс модульного тестирования для тестирования моего производителя Kafka.

Он работает правильно в локальной системе.Но когда я пытаюсь встроить его в gitlab, он проваливается из-за теста.

com.project.kafka.KafkaUtilTest > classMethod FAILED
org.I0Itec.zkclient.exception.ZkTimeoutException

Но у меня нет теста под названием classMethod где-то в тесте.

Почему этопроисходит и как решить эту проблему?

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = WebEnvironment.RANDOM_PORT, classes = TestApplication.class)
@ActiveProfiles("test")
@EmbeddedKafka
public class KafkaUtilTest {

    private static String TOPIC = "PE";

    @Autowired
    KafkaUtil kafkaUtil;

    @Autowired
    ConfigurationProperties configProperties;

    Request request;
    Response response;
    Consumer<String, Object> consumer;
    HashMap<String, String> expectedHeaderValueMap;

    @ClassRule
    public static EmbeddedKafkaRule embeddedKafkarule = new EmbeddedKafkaRule(1, true, TOPIC);

    @BeforeClass
    public static void setUpBeforeClass() throws Exception {
        System.setProperty("spring.kafka.producer.bootstrap-servers",
                embeddedKafkarule.getEmbeddedKafka().getBrokersAsString());

    }

    @Before
    public void init() {
        readFile("0211");
        expectedHeaderValueMap = getExpectedHeaderValueMap();
        Map<String, Object> consumerConfigs = new HashMap<>(
                KafkaTestUtils.consumerProps("consumer", "true", embeddedKafkarule.getEmbeddedKafka()));
        consumerConfigs.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        consumerConfigs.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);

        consumer = new DefaultKafkaConsumerFactory<String, Object>(consumerConfigs).createConsumer();

        List<String> topics = new ArrayList<>();
        topics.add(TOPIC);

        TopicPartition topicPartition1 = new TopicPartition(TOPIC, 0);
        TopicPartition topicPartition2 = new TopicPartition(TOPIC, 1);
        List<TopicPartition> topicPartitions = new ArrayList<TopicPartition>();
        topicPartitions.add(topicPartition1);
        topicPartitions.add(topicPartition2);
        consumer.assign(topicPartitions);
        consumer.seekToBeginning(topicPartitions);

    }

    @Test   
    public void testPublish() throws Exception {
        kafkaUtil.publishToKafka(request, response);
        kafkaUtil.kafkaTemplate.flush();
        ConsumerRecord<String, Object> consumedRecord = KafkaTestUtils.getSingleRecord(consumer, TOPIC);
        assertRecord(consumedRecord);
    }


    private void readFile(String testSequenceNo) {
        ObjectMapper om = new ObjectMapper();

        try {
            request = om.readValue(
                    this.getClass().getClassLoader().getResourceAsStream(
                            "requests/request" + testSequenceNo + ".json"),
                    SchedulingCallRequestDTO.class);
        } catch (IOException e) {
            e.printStackTrace();
        }
        try {
            response = om.readValue(this.getClass().getClassLoader().getResourceAsStream(
                    "responsesv2/response" + testSequenceNo + ".json"),
                    ScheduleOrderResponseDTOv2.class);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

Это мой тест.

Я удалил часть подтверждения, чтобы уменьшить размер