Тест Spring Kafka со встроенным Kafka не удалось удалить журналы

Я использую spring kafka со встроенной kafka для теста JUnit, он выдает ошибку для каждого теста в Windows:

Error deleting C:\Users:LXX691\AppData\Local\Temp\kafka-1103610162480947200/.lock: The process cannot access the file because it is being used by another process.

Я просто выполнил базовую конфигурацию, как показано ниже

@SpringBootTest(webEnvironment = RANDOM_PORT)
@RunWith(SpringRunner.class)
public class KafkaTest {
  @Autowired
  EmbeddedKafkaBroker broker;

  @Before
  void setUp() throws Exception() {
    // setup producer and consumers
  }

  @Test
  void test() {
    producer.send(new ProducerRecord<>("topic", "content"));
  }
}

Приветствуются любые предложения по решению или обходной путь.


person Jakim    schedule 23.08.2019    source источник
comment
Есть ли обходной путь, чтобы пройти тест, поскольку это известная проблема, с которой мы не можем справиться?   -  person Shamil Puthukkot    schedule 04.10.2019
comment
Я не думаю, что это приведет к провалу теста.   -  person Archimedes Trajano    schedule 24.09.2020


Ответы (1)


Это известная проблема в Apache Kafka: https://issues.apache.org/jira/browse/KAFKA-8145.

К сожалению, в Spring Kafka мы ничего не можем сделать по этому поводу.

См. Дополнительную информацию здесь: Kafka: невозможно запустить Kafka - процесс не может получить доступ к файлу 00000000000000000000.timeindex и здесь https://github.com/spring-projects/spring-kafka/issues/194

person Artem Bilan    schedule 23.08.2019