KafkaContainerWrapperConfig.groovy

@Configuration
class KafkaContainerWrapperConfig {
    private static final KafkaContainerWrapper containerWrapper = KafkaContainerWrapper.getContainer()

    @Bean
    NewTopic userData() {
        return new NewTopic("user-data", 1, (short) 1)
    }

}