webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
properties = {
"consumer.bootstrap-server=${spring.embedded.kafka.brokers}",
- "consumer.topic=" + TOPIC })
+ "consumer.topic=" + TOPIC,
+ "spring.mongodb.embedded.version=4.4.13" })
@EmbeddedKafka(topics = TOPIC)
@AutoConfigureDataMongo
public class ApplicationIT