elasticsearch and camel integration -


I am trying to integrate the camel with elasticsearch ApplicationContext.xml contains the following

  & lt; Route id = "timer-to-console" & gt; & Lt; From Yuri = "Timer: // Foo? Default Rate = True & amp; Period = 10s" / & gt; & Lt; Change & gt; & Lt; Simple & gt; Hello web application, how are you? & Lt; / simple & gt; & Lt; / Change & gt; & Lt; Yuri = "stream: out" /> & Lt; From Yuri = "Elastic Search: // Local" /> & Lt; / Route & gt;   

Then when I run

  mvn jetty: run   

, I'm getting the following >

  Very Quarantine = 0, Removed Time = Mon 21 Apr 13:14:43 PDT 2014} BodyType String Body Hello Web Application, How are you? ] stack trace ----------------------------------------------- - ---------------------------------------- java.lang.IllegalArgumentException: operation is unavailable $ ProcessorToAsyncProcessorBridge.process (AsyncProcessorConverterHelper.java:61) on Org.apache.camel.component.elasticsearch.ElasticsearchProducer.process (ElasticsearchProducer.java:54) org.apache.camel.util.AsyncProcessorConverterHelper   < p>  elasticsearch: // clusterName [options] I need to specify  

/ code>

thanks,

The following example with a quick look on the page shown:

elasticsearch: // local? Operation = INDEX and indexName = twitter and indexType = tweet

This will be in an index (index) to index twitter in a type of tweet Has been named. You can use whatever value you want for indexName and indexType.

Update: Resilient camber is searching for component documentation again ... I think the local as the server name in the elastic search connection , You have to run local elastic search examples with local clust users. By default, flexible checker configuration (elasticsearch.yml) is set to run with the clustered user of Lolastic search

Comments

Popular posts from this blog

Verilog Error: output or inout port "Q" must be connected to a structural net expression -

jasper reports - How to center align barcode using jasperreports and barcode4j -

c# - ASP.NET MVC - Attaching an entity of type 'MODELNAME' failed because another entity of the same type already has the same primary key value -