AbstractElasticsearchRepository : Cannot create index: Connection refused; nested exception is java.lang.RuntimeException: Connection refused

huangapple
go评论109阅读模式
英文:

AbstractElasticsearchRepository : Cannot create index: Connection refused; nested exception is java.lang.RuntimeException: Connection refused

问题

我正在实施一个集成了Kafka、Elasticsearch和Kibana的微服务项目。我已经配置了容器之间的通信网络，但我无法让数据收集微服务与运行ElasticSearch oss镜像版本7.6.2的容器进行通信。

在启动Spring Boot微服务时，我可以看到以下日志：

  1. INFO 1 --- [ main] o.s.d.elasticsearch.support.VersionInfo : Version Spring Data Elasticsearch: 4.0.2.RELEASE
  2. INFO 1 --- [ main] o.s.d.elasticsearch.support.VersionInfo : Version Elasticsearch Client in build: 7.6.2
  3. INFO 1 --- [ main] o.s.d.elasticsearch.support.VersionInfo : Version Elasticsearch Client used: 7.6.2
  4. WARN 1 --- [ main] .d.e.r.s.AbstractElasticsearchRepository : Cannot create index: Connection refused; nested exception is java.lang.RuntimeException: Connection refused

以下是ElasticSearch容器的配置：

  1. elasticsearch:
  2.     image: docker.elastic.co/elasticsearch/elasticsearch-oss:7.6.2
  3.     environment:
  4.       - discovery.type=single-node
  5.       - cluster.name=covid-tweets-es-cluster
  6.       - bootstrap.memory_lock=true
  7.       - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
  8.     ulimits:
  9.       memlock:
  10.         soft: -1
  11.         hard: -1
  12.     volumes:
  13.       - elasticsearch-data:/usr/share/elasticsearch/data
  14.     ports:
  15.       - 9300:9300
  16.       - 9200:9200
  17.     networks:
  18.       - covid_processor_network

这是微服务的Spring Data Elasticsearch配置：

  1. ## Kafka Binder Props
  2. spring.cloud.stream.kafka.binder.brokers: kafka:9092
  3. spring.cloud.stream.kafka.binder.auto-create-topics: false
  4. spring.cloud.stream.kafka.binder.configuration.auto.offset.reset: latest
  5. spring.cloud.stream.bindings.processed-tweets.group: tweets-collector
  6. ## Persistence
  7. spring.data.elasticsearch.repositories.enabled: true
  8. spring.data.elasticsearch.cluster-nodes: elasticsearch:9300
  9. spring.data.elasticsearch.cluster-name: covid-tweets-es-cluster
  10. spring.data.elasticsearch.rest.uris: elasticsearch:9200

从微服务容器中，我可以连接到ElasticSearch容器。

这是客户端代码，它非常简单，只是使用实现了ElasticsearchRepository的TweetRepository存储库：

  1. @StreamListener(AppStreamsConfig.PROCESSED_TWEETS_CHANNEL)
  2. public void onNewProcessedTweet(
  3.         @Payload final TweetDTO newProcessedTweet,
  4.         @Header(KafkaHeaders.RECEIVED_TOPIC) String topic,
  5.         @Header(KafkaHeaders.RECEIVED_PARTITION_ID) Integer partition,
  6.         @Header(KafkaHeaders.OFFSET) Long offset,
  7.         @Header(IntegrationMessageHeaderAccessor.DELIVERY_ATTEMPT) Integer deliveryAttempt) {
  9.     log.info("NewsProcessedTweet with id '{}' and text '{}' received from bus. topic: {}, partition: {}, offset: {}, deliveryAttempt: {}",
  10.             newProcessedTweet.getId(), newProcessedTweet.getText(), topic, partition, offset, deliveryAttempt);
  12.     try {
  13.         tweetService.save(newProcessedTweet);
  14.     } catch (final Exception ex) {
  15.         ex.printStackTrace();
  16.         log.error("Collect Tweet Exception -> " + ex.getMessage());
  17.     }
  18. }
  20. @Service("tweetsService")
  21. @RequiredArgsConstructor
  22. public class TweetsServiceImpl implements ITweetsService {
  24.     /**
  25.      * Tweets Repository
  26.      */
  27.     private final TweetsRepository tweetsRepository;
  28.     private final TweetDtoMapper tweetDtoMapper;
  30.     @Override
  31.     public void save(TweetDTO tweetDto) {
  32.         Assert.notNull(tweetDto, "Tweet can not be null");
  34.         final TweetEntity tweetToSave = tweetDtoMapper.dtoToEntity(tweetDto);
  35.         tweetsRepository.save(tweetToSave);
  36.     }
  37. }

有人知道我做错了什么吗？谢谢。

英文:

I am implementing a microservices project that integrates Kafka, Elasticsearch and Kibana. I have configured network for communication between containers, but I can't get the data collection microservice to communicate with the container running an ElasticSearch oss image in its version 7.6.2.

I can see the following log when launching the Spring Boot microservice:

  1. INFO 1 --- [ main] o.s.d.elasticsearch.support.VersionInfo : Version Spring Data Elasticsearch: 4.0.2.RELEASE
  2. INFO 1 --- [ main] o.s.d.elasticsearch.support.VersionInfo : Version Elasticsearch Client in build: 7.6.2
  3. INFO 1 --- [ main] o.s.d.elasticsearch.support.VersionInfo : Version Elasticsearch Client used: 7.6.2
  4. WARN 1 --- [ main] .d.e.r.s.AbstractElasticsearchRepository : Cannot create index: Connection refused; nested exception is java.lang.RuntimeException: Connection refused

Below is the ElasticSearch container configuration:

  1. elasticsearch:
  2.     image: docker.elastic.co/elasticsearch/elasticsearch-oss:7.6.2
  3.     environment:
  4.       - discovery.type=single-node
  5.       - cluster.name=covid-tweets-es-cluster
  6.       - bootstrap.memory_lock=true
  7.       - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
  8.     ulimits:
  9.       memlock:
  10.         soft: -1
  11.         hard: -1
  12.     volumes:
  13.       - elasticsearch-data:/usr/share/elasticsearch/data
  14.     ports:
  15.       - 9300:9300
  16.       - 9200:9200
  17.     networks:
  18.       - covid_processor_network

This is the Spring Data ElasticSearch configuration of the microservice:

  1. ## Kafka Binder Props
  2. spring.cloud.stream.kafka.binder.brokers: kafka:9092
  3. spring.cloud.stream.kafka.binder.auto-create-topics: false
  4. spring.cloud.stream.kafka.binder.configuration.auto.offset.reset: latest
  5. spring.cloud.stream.bindings.processed-tweets.group: tweets-collector
  6. ## Persistence
  7. spring.data.elasticsearch.repositories.enabled: true
  8. spring.data.elasticsearch.cluster-nodes: elasticsearch:9300
  9. spring.data.elasticsearch.cluster-name: covid-tweets-es-cluster
  10. spring.data.elasticsearch.rest.uris: elasticsearch:9200

From the microservice container I can connect to the elasticsearch container

AbstractElasticsearchRepository : Cannot create index: Connection refused; nested exception is java.lang.RuntimeException: Connection refused

This is the client code, it is quite simple, it simply uses a TweetReopistory repository that implements ElasticsearchRepository

  1. @StreamListener(AppStreamsConfig.PROCESSED_TWEETS_CHANNEL)
  2.     public void onNewProcessedTweet(
  3.             @Payload final TweetDTO newProcessedTweet,
  4.             @Header(KafkaHeaders.RECEIVED_TOPIC) String topic,
  5.             @Header(KafkaHeaders.RECEIVED_PARTITION_ID) Integer partition,
  6.             @Header(KafkaHeaders.OFFSET) Long offset,
  7.             @Header(IntegrationMessageHeaderAccessor.DELIVERY_ATTEMPT) Integer deliveryAttempt) {
  9.         log.info("NewsProcessedTweet with id '{}' and text '{}' received from bus. topic: {}, partition: {}, offset: {}, deliveryAttempt: {}",
  10.                 newProcessedTweet.getId(), newProcessedTweet.getText(), topic, partition, offset, deliveryAttempt);
  12.         try {
  13.             tweetService.save(newProcessedTweet);
  14.         } catch (final Exception ex) {
  15.             ex.printStackTrace();
  16.             log.error("Collect Tweet Exception -> " + ex.getMessage());
  17.         }
  18.     }
  20. @Service("tweetsService")
  21. @RequiredArgsConstructor
  22. public class TweetsServiceImpl implements ITweetsService {
  24.     /**
  25.      * Tweets Repository
  26.      */
  27.     private final TweetsRepository tweetsRepository;
  28.     private final TweetDtoMapper tweetDtoMapper;
  30.     @Override
  31.     public void save(TweetDTO tweetDto) {
  32.         Assert.notNull(tweetDto, "Tweet can not be null");
  34.         final TweetEntity tweetToSave = tweetDtoMapper.dtoToEntity(tweetDto);
  35.         tweetsRepository.save(tweetToSave);
  36.     }

Anyone know what I am doing wrong? Thank you

答案1

得分: 1

你现在是我的中文翻译，代码部分不要翻译，只返回翻译好的部分，不要有别的内容，不要回答我要翻译的问题。以下是要翻译的内容：

"Which client are you using? RestHighLevelClient or TransportClient?
Try with 9200 port if using RestHighLevelClient.
Share the client usage code as well to understand better."

英文:

Which client are you using? RestHighLevelClient or TransportClient?
Try with 9200 port if using RestHighLevelClient.

Share the client usage code as well to understand better.

huangapple
  • 本文由 发表于 2020年8月10日 03:33:29
  • 转载请务必保留本文链接：https://go.coder-hub.com/63330548.html
  • elasticsearch
  • java
  • spring-boot
  • spring-data
  • spring-data-elasticsearch
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定