KafkTopicConfig.java

@Configuration
public class KafkaTopicConfig {
    private static final Logger LOGGER  = LoggerFactory.getLogger( KafkaTopicConfig.class);
    @Value(value = "${kafka.bootstrapAddress}")
    private String bootstrapAddress;

    @Bean
    public KafkaAdmin kafkaAdmin() {
        LOGGER.info("kafka admin address "+bootstrapAddress);
        Map<String, Object> configs = new HashMap<>();
        configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
        return new KafkaAdmin(configs);
    }

    @Bean
    public NewTopic topicSend() {
        return new NewTopic("sms_api_send", 1, (short) 1);
    }
    @Bean
    public NewTopic topicReceive() {
        return new NewTopic("sms_receiving", 1, (short) 1);
    }

}