Spring Kafka Config blog

TopicAdministrator.java

@Configuration
public class TopicAdministrator {
  private final TopicConfigurations configurations;
  private final GenericWebApplicationContext context;

  public TopicAdministrator(TopicConfigurations configurations,	GenericWebApplicationContext genericContext) {
    this.configurations = configurations;
    this.context = genericContext;
  }
  
  @PostConstruct
  public void createTopics() {
    configurations
        .getTopics()
        .ifPresent(this::initializeBeans);
  }

  private void initializeBeans(List<TopicConfiguration> topics) {
    topics.forEach(t -> { 
      context.registerBean(t.getName(), NewTopic.class, t::toNewTopic);
    });
  }
}