Represents an Elasticsearch endpoint.
Name | Kind | Group | Required | Default | Type | Enum | Description |
---|---|---|---|---|---|---|---|
clusterName | path | producer | true | java.lang.String | Name of cluster or use local for local mode | ||
consistencyLevel | parameter | producer | DEFAULT | org.elasticsearch.action.WriteConsistencyLevel | DEFAULT ONE QUORUM ALL |
The write consistency level to use with INDEX and BULK operations (can be any of ONE, QUORUM, ALL or DEFAULT) | |
data | parameter | producer | java.lang.Boolean | Is the node going to be allowed to allocate data (shards) to it or not. This setting map to the node.data setting. | |||
indexName | parameter | producer | java.lang.String | The name of the index to act against | |||
indexType | parameter | producer | java.lang.String | The type of the index to act against | |||
ip | parameter | producer | java.lang.String | The TransportClient remote host ip to use | |||
operation | parameter | producer | true | java.lang.String | INDEX BULK BULK_INDEX GET_BY_ID DELETE |
What operation to perform | |
port | parameter | producer | 9300 | int | The TransportClient remote port to use (defaults to 9300) | ||
replicationType | parameter | producer | DEFAULT | org.elasticsearch.action.support.replication.ReplicationType | SYNC ASYNC DEFAULT |
The replication type to use with INDEX and BULK operations (can be any of SYNC, ASYNC or DEFAULT) | |
transportAddresses | parameter | producer | java.lang.String | Comma separated list with ip:port formatted remote transport addresses to use. The ip and port options must be left blank for transportAddresses to be considered instead. | |||
exchangePattern | parameter | advanced | InOnly | org.apache.camel.ExchangePattern | InOnly RobustInOnly InOut InOptionalOut OutOnly RobustOutOnly OutIn OutOptionalIn |
Sets the default exchange pattern when creating an exchange | |
synchronous | parameter | advanced | false | boolean | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). |