小编Mig*_*dez的帖子

我有这个 propelr.properties：

elasticsearch.port=443
elasticsearch.protocol=https
elasticsearch.index=contentlink
elasticsearch.type=cl
kafka.max-poll-records=1000
kafka.topic=es-indexer-topic
kafka.group.id=espn-content-link-kafka-es-connector-group
kafka.concurrency-level=4

这个文件是我获取端口的地方：

@Component
final class ElasticSearchClientFactory extends 
AbstractFactoryBean<RestHighLevelClient> {

    private final RestHighLevelClient client;

    ElasticSearchClientFactory(
            final @Value("${elasticsearch.hostname}") String hostname,
            final @Value("${elasticsearch.port}") int port,
            final @Value("${elasticsearch.protocol}") String protocol
    ) {
        client = new RestHighLevelClient(RestClient.builder(new 
 HttpHost(hostname, port, protocol)));
    }

    @Override
    public Class<?> getObjectType() {
        return RestHighLevelClient.class;
    }

    @Override
    protected RestHighLevelClient createInstance() throws Exception {
        return client;
    }

    @Override
    public void destroy() throws Exception {
        if (Objects.nonNull(client)) {
            client.close();
        }
    }
}

这部分代码是@Configuration 所在的位置：

@EnableKafka …