| @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