3

我正在使用带有嵌入式 kafka 的 spring 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"));
  }
}

任何解决建议或任何解决方法表示赞赏。

4

1 回答 1

2

这是 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

于 2019-08-23T13:51:03.970 回答