public abstract class KafkaTestUtils
{
@TestConfiguration
- @Import(KafkaServicesConfiguration.class)
@EnableConfigurationProperties(ChatBackendProperties.class)
+ @Import(KafkaServicesConfiguration.class)
@TestPropertySource(properties = {
"spring.main.allow-bean-definition-overriding=true",
"chat.backend.services=kafka",
"chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
"spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
})
- public static class KafkaTestConfiguration
+ static class KafkaTestConfiguration
{
@Bean
WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel)