KafkaUiApplication.java 1.2 KB

1234567891011121314151617181920212223242526272829303132
  1. package com.provectus.kafka.ui;
  2. import com.provectus.kafka.ui.util.DynamicConfigOperations;
  3. import java.util.Map;
  4. import org.apache.kafka.clients.admin.AdminClient;
  5. import org.apache.kafka.clients.admin.AdminClientConfig;
  6. import org.springframework.boot.autoconfigure.SpringBootApplication;
  7. import org.springframework.boot.autoconfigure.ldap.LdapAutoConfiguration;
  8. import org.springframework.boot.builder.SpringApplicationBuilder;
  9. import org.springframework.context.ConfigurableApplicationContext;
  10. import org.springframework.scheduling.annotation.EnableAsync;
  11. import org.springframework.scheduling.annotation.EnableScheduling;
  12. @SpringBootApplication(exclude = LdapAutoConfiguration.class)
  13. @EnableScheduling
  14. @EnableAsync
  15. public class KafkaUiApplication {
  16. public static void main(String[] args) {
  17. AdminClient ac = AdminClient.create(Map.of(
  18. AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"
  19. ));
  20. System.out.println(ac);
  21. }
  22. public static ConfigurableApplicationContext startApplication(String[] args) {
  23. return new SpringApplicationBuilder(KafkaUiApplication.class)
  24. .initializers(DynamicConfigOperations.dynamicConfigPropertiesInitializer())
  25. .build()
  26. .run(args);
  27. }
  28. }