@Configuration | |
class KafkaContainerWrapperConfig { | |
private static final KafkaContainerWrapper containerWrapper = KafkaContainerWrapper.getContainer() | |
@Bean | |
NewTopic userData() { | |
return new NewTopic("user-data", 1, (short) 1) | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment