Spring-Kafka-тест в SSL

Question

Привет, я пытаюсь использовать spring-kafka-test для тестирования встроенного kafka в моем тесте.

Я не могу найти проект в репозиториях Github Spring.

Также хотелось бы узнать, может ли встроенная кафка библиотеки работать не только в PLAIN_TEXT, но и в протоколе SSL.

С уважением.

Answer 1

Для запуска Embeddedkafka вы можете аннотировать свой тестовый класс с помощью этого

@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 я этого не сделал, но было бы любопытно найти ответ.