[
https://issues.apache.org/jira/browse/CAMEL-17184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikhil updated CAMEL-17184:
---------------------------
Description:
Hello,
I am using *Apache Camel 3.12.0* to communicate with {*}Elasticsearch 7.13.0{*}.
Elasticsearch is secured i.e. *SSL HTTPs* protected.
Below is the code snippet to index the data into Elasticsearch using camel.
{code:java}
ElasticsearchComponent camelESComponent = new ElasticsearchComponent();
camelESComponent.setHostAddresses("127.0.0.1:9200");
camelESComponent.setUser("elastic");
camelESComponent.setPassword("password");
camelESComponent.setEnableSSL(true);
camelContext.addComponent("elasticsearch-rest", camelESComponent);
// route
from("direct:index").to("elasticsearch-rest://myescluster?operation=Index&indexName=twitter");{code}
I am getting below error while performing Index operation.
{code:java}
org.apache.http.ConnectionClosedException: Connection is closed
at
org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:871)
~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)
~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)
~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1654)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1624)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1594)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.index(RestHighLevelClient.java:1011)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.apache.camel.component.elasticsearch.ElasticsearchProducer.process(ElasticsearchProducer.java:170)
~[camel-elasticsearch-rest-3.12.0.jar:3.12.0]
at
org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66)
~[camel-support-3.12.0.jar:3.12.0]
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
[camel-core-processor-3.12.0.jar:3.12.0]
at
org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
[camel-core-processor-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.executeFromQueue(DefaultReactiveExecutor.java:210)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultReactiveExecutor.executeFromQueue(DefaultReactiveExecutor.java:74)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.await(DefaultAsyncProcessorAwaitManager.java:96)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:85)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:190)
[camel-support-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:172)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultProducerTemplate.requestBody(DefaultProducerTemplate.java:413)
[camel-base-engine-3.12.0.jar:3.12.0] {code}
I am getting above error only when I use *Camel 3.12.0* with SSL Elasticsearch,
Without SSL works fine with this.
If I downgrade component to *Camel 3.2.0* / *3.4.0* then With and Without SSL
both works perfectly fine.
was:
Hello,
I am using *Apache Camel 3.12.0* to communicate with {*}Elasticsearch 7.13.0{*}.
Elasticsearch is secured i.e. *SSL HTTPs* protected.
Below is the code snippet to index the data into Elasticsearch using camel.
{code:java}
ElasticsearchComponent camelESComponent = new ElasticsearchComponent();
camelESComponent.setHostAddresses("127.0.0.1:9200");
camelESComponent.setUser("elastic");
camelESComponent.setPassword("password");
camelESComponent.setEnableSSL(true);
camelContext.addComponent("elasticsearch-rest", camelESComponent);
// route
from("direct:index").to("elasticsearch-rest://myescluster?operation=Index&indexName=twitter");{code}
I am getting below error while performing Index operation.
{code:java}
org.apache.http.ConnectionClosedException: Connection is closed
at
org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:871)
~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)
~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
at org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)
~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1654)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1624)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1594)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.elasticsearch.client.RestHighLevelClient.index(RestHighLevelClient.java:1011)
~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
at
org.apache.camel.component.elasticsearch.ElasticsearchProducer.process(ElasticsearchProducer.java:170)
~[camel-elasticsearch-rest-3.12.0.jar:3.12.0]
at
org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66)
~[camel-support-3.12.0.jar:3.12.0]
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
[camel-core-processor-3.12.0.jar:3.12.0]
at
org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
[camel-core-processor-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.executeFromQueue(DefaultReactiveExecutor.java:210)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultReactiveExecutor.executeFromQueue(DefaultReactiveExecutor.java:74)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.await(DefaultAsyncProcessorAwaitManager.java:96)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:85)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:190)
[camel-support-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:172)
[camel-base-engine-3.12.0.jar:3.12.0]
at
org.apache.camel.impl.engine.DefaultProducerTemplate.requestBody(DefaultProducerTemplate.java:413)
[camel-base-engine-3.12.0.jar:3.12.0] {code}
I am getting above error only when I use {*}Camel 3.12.0{*}.
If I downgrade component to *Camel 3.2.0* / *3.4.0* above code works perfectly
fine.
> Failed to connect with secured Elasticsearch [SSL]
> --------------------------------------------------
>
> Key: CAMEL-17184
> URL: https://issues.apache.org/jira/browse/CAMEL-17184
> Project: Camel
> Issue Type: Bug
> Components: camel-elasticsearch-rest
> Affects Versions: 3.12.0
> Reporter: Nikhil
> Priority: Major
>
> Hello,
> I am using *Apache Camel 3.12.0* to communicate with {*}Elasticsearch
> 7.13.0{*}.
> Elasticsearch is secured i.e. *SSL HTTPs* protected.
> Below is the code snippet to index the data into Elasticsearch using camel.
>
> {code:java}
> ElasticsearchComponent camelESComponent = new ElasticsearchComponent();
> camelESComponent.setHostAddresses("127.0.0.1:9200");
> camelESComponent.setUser("elastic");
> camelESComponent.setPassword("password");
> camelESComponent.setEnableSSL(true);
> camelContext.addComponent("elasticsearch-rest", camelESComponent);
> // route
> from("direct:index").to("elasticsearch-rest://myescluster?operation=Index&indexName=twitter");{code}
>
> I am getting below error while performing Index operation.
>
> {code:java}
> org.apache.http.ConnectionClosedException: Connection is closed
> at
> org.elasticsearch.client.RestClient.extractAndWrapCause(RestClient.java:871)
> ~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
> at
> org.elasticsearch.client.RestClient.performRequest(RestClient.java:283)
> ~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
> at
> org.elasticsearch.client.RestClient.performRequest(RestClient.java:270)
> ~[elasticsearch-rest-client-7.13.0.jar:7.13.0]
> at
> org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1654)
> ~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
> at
> org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1624)
> ~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
> at
> org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1594)
> ~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
> at
> org.elasticsearch.client.RestHighLevelClient.index(RestHighLevelClient.java:1011)
> ~[elasticsearch-rest-high-level-client-7.13.0.jar:7.13.0]
> at
> org.apache.camel.component.elasticsearch.ElasticsearchProducer.process(ElasticsearchProducer.java:170)
> ~[camel-elasticsearch-rest-3.12.0.jar:3.12.0]
> at
> org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66)
> ~[camel-support-3.12.0.jar:3.12.0]
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
> [camel-core-processor-3.12.0.jar:3.12.0]
> at
> org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
> [camel-core-processor-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.executeFromQueue(DefaultReactiveExecutor.java:210)
> [camel-base-engine-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.DefaultReactiveExecutor.executeFromQueue(DefaultReactiveExecutor.java:74)
> [camel-base-engine-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.await(DefaultAsyncProcessorAwaitManager.java:96)
> [camel-base-engine-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:85)
> [camel-base-engine-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
> [camel-base-engine-3.12.0.jar:3.12.0]
> at
> org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:190)
> [camel-support-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
> [camel-base-engine-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:172)
> [camel-base-engine-3.12.0.jar:3.12.0]
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.requestBody(DefaultProducerTemplate.java:413)
> [camel-base-engine-3.12.0.jar:3.12.0] {code}
>
> I am getting above error only when I use *Camel 3.12.0* with SSL
> Elasticsearch, Without SSL works fine with this.
> If I downgrade component to *Camel 3.2.0* / *3.4.0* then With and Without SSL
> both works perfectly fine.
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
