spring-kafka- SSL中的测试

Question

您好，我正在尝试使用spring-kafka-test来测试我的测试中的嵌入式kafka。

我在Github spring repos中找不到这个项目。

另外，我想知道该库的嵌入式kafka是否不仅可以在PLAIN_TEXT中工作，而且还可以在SSL协议中工作。

致以问候。

Answer 1

要启动Embeddedkafka，可以用下面的代码注释Test类

@EnableKafka @EmbeddedKafka(partitions = 1, controlledShutdown = true, topics = {"topic1","topic2"}) public class myTest { }

此外，您还可以在测试中获得kafka和zookeeper地址，您可以使用以下命令进行连接

System.getProperty("spring.embedded.kafka.brokers") System.getProperty("spring.embedded.zookeeper.connect")

对于SSL，我没有这样做，但我很好奇地想找到答案。