Spring启动嵌入式Kafka h2 数据库单元测试

Question

所以我用了这个嵌入Kafka的例子，还有这个

我对这个示例做了一点更改，并用一些数据库（如h2db）更新了kafka侦听器。

现在在我的单元测试中，当我想检查数据在数据库中是否可用时，我得到NULL。另外，我不确定如何手动检查数据库，因为h2是一个内存基础数据库。

这是更新的部分：在接收器类中

@Autowired
DataTableRepository repository;

@KafkaListener(topics = "${kafkatest.topic}")
public void receive(ConsumerRecord<String, DataTable> consumerRecord) {
    LOGGER.info("received payload='{}'", consumerRecord.toString());
    repository.save(consumerRecord.value());
    latch.countDown();
}

在单元测试中:

@Autowired 
DataTableRepository repository;

@Test
public void testReceive() throws Exception {
DataTable table = new DataTable(1, "Sending with default template");

template.send(topic, table);

receiver.getLatch().await(10000, TimeUnit.MILLISECONDS);

DataTable dt = repository.getOne(table.getId());
assertNotNull(dt);
assertThat(receiver.getLatch().getCount(), equalTo(0L));
}

但 dt 始终为空。此外，我也无法检查数据库，因为它在测试停止后停止。有人知道如何使它可行吗？

Answer 1

是否已在测试属性文件中设置属性“Kafka测试主题”？这可能是您的侦听器未侦听指定主题的原因。