import org.junit.jupiter.api.BeforeAll;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.context.TestConfiguration;
import org.springframework.boot.test.mock.mockito.MockBean;
import org.springframework.context.annotation.Import;
import org.springframework.kafka.core.KafkaTemplate;
"chat.backend.kafka.data-channel-topic=" + DATA_TOPIC,
"chat.backend.kafka.num-partitions=10",
})
-@Import(KafkaTestUtils.KafkaTestConfiguration.class)
@EmbeddedKafka(
topics = { INFO_TOPIC, DATA_TOPIC },
partitions = 10)
{
KafkaTestUtils.joinConsumerTasks(consumerTaskRunner);
}
+
+
+ @TestConfiguration
+ @Import(KafkaTestUtils.KafkaTestConfiguration.class)
+ static class KafkaConfigurationITConfiguration
+ {
+ }
}