Rapository在与Kafkalistener的集成测试中无法连接到Postgres（testContainers）

Question

我使用带有Postgres DB的测试容器运行集成测试。当我使用kafkatemplate将JSON消息发送到Kafka主题时，我会得到SQL例外：

[W] SqlExceptionHelper - SQL Error: 0, SQLState: 42P01 
[E] SqlExceptionHelper - ERROR: relation "test_db.test_schema" does not exist

could not extract ResultSet; SQL [n/a]; nested exception is org.hibernate.exception.SQLGrammarException: could not extract ResultSet
org.springframework.dao.InvalidDataAccessResourceUsageException: could not extract ResultSet; SQL [n/a]; nested exception is org.hibernate.exception.SQLGrammarException: could not extract ResultSet

我的测试如下：

@Autowired
TestRepository repository;

@Autowired
KafkaTemplate<String, String> kafkaTemplate;

private void publishFile(String fileName) {
    kafkaTemplate.send("test.topic", "1", readFile(fileName));
}

@Test
public void test_1() {
    publishFile("json/test_1.json");
    await().atMost(5, SECONDS).until(()-> repository.findAll().size() == 1);
}

当我调用PublishFile消息时，到达@kafkalistener，

@KafkaListener(topics = "test.topic")
public void onRecieve(@Payload String json, @Header(name = RECIEVED_MESSAGE_KEY) String key) {
    TestEntity entity = mapper.readValue(json, TestEntity.class);
    repository.save(entity);
}

但是当我直接在类似的测试中使用存储库时：

@Test
public void test_1() {
    repository.findAll();
}

一切正常。我可以从存储库写信并阅读。

另外，我可以在此测试中访问存储库：

@Test
public void test_1() {
    TestEntity entity = mapper.readValue(readFile("json/test_1.json"), TestEntity.class);
    repository.save(entity);
    publishFile("json/test_1.json");
    log.info(repository.findAll());
    await().atMost(5, SECONDS).until(()-> repository.findAll().size() == 1);
}

在主线程中，我可以写入存储库，然后在sendig消息到@kafkalistener之后，我可以从存储库中阅读。但是在@kafkalistener线程中，我不能。我想应该存在相同的测试上下文，但看起来不是。如何使用存储库与@kafkalistener线程中的Postgres容器进行互相关？