camel-milo-client-kafka-connector source configuration

When using camel-milo-client-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:

<dependency>
  <groupId>org.apache.camel.kafkaconnector</groupId>
  <artifactId>camel-milo-client-kafka-connector</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel Kafka connector version -->
</dependency>

To use this Source connector in Kafka connect you’ll need to set the following connector.class

connector.class=org.apache.camel.kafkaconnector.miloclient.CamelMiloclientSourceConnector

The camel-milo-client source connector supports 53 options, which are listed below.

Name Description Default Priority

camel.source.path.endpointUri

The OPC UA server endpoint

null

HIGH

camel.source.endpoint.clientId

A virtual client id to force the creation of a new connection instance

null

MEDIUM

camel.source.endpoint.defaultAwaitWrites

Default await setting for writes

false

MEDIUM

camel.source.endpoint.discoveryEndpointSuffix

A suffix for endpoint URI when discovering

null

MEDIUM

camel.source.endpoint.discoveryEndpointUri

An alternative discovery URI

null

MEDIUM

camel.source.endpoint.method

The method definition (see Method ID)

null

MEDIUM

camel.source.endpoint.node

The node definition (see Node ID)

null

MEDIUM

camel.source.endpoint.samplingInterval

The sampling interval in milliseconds

"0.0"

MEDIUM

camel.source.endpoint.bridgeErrorHandler

Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.

false

MEDIUM

camel.source.endpoint.exceptionHandler

To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.

null

MEDIUM

camel.source.endpoint.exchangePattern

Sets the exchange pattern when the consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut]

null

MEDIUM

camel.source.endpoint.basicPropertyBinding

Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities

false

MEDIUM

camel.source.endpoint.synchronous

Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).

false

MEDIUM

camel.source.endpoint.allowedSecurityPolicies

A set of allowed security policy URIs. Default is to accept all and use the highest.

null

MEDIUM

camel.source.endpoint.applicationName

The application name

"Apache Camel adapter for Eclipse Milo"

MEDIUM

camel.source.endpoint.applicationUri

The application URI

"http://camel.apache.org/EclipseMilo/Client"

MEDIUM

camel.source.endpoint.channelLifetime

Channel lifetime in milliseconds

null

MEDIUM

camel.source.endpoint.keyAlias

The name of the key in the keystore file

null

MEDIUM

camel.source.endpoint.keyPassword

The key password

null

MEDIUM

camel.source.endpoint.keyStorePassword

The keystore password

null

MEDIUM

camel.source.endpoint.keyStoreType

The key store type

null

MEDIUM

camel.source.endpoint.keyStoreUrl

The URL where the key should be loaded from

null

MEDIUM

camel.source.endpoint.maxPendingPublishRequests

The maximum number of pending publish requests

null

MEDIUM

camel.source.endpoint.maxResponseMessageSize

The maximum number of bytes a response message may have

null

MEDIUM

camel.source.endpoint.overrideHost

Override the server reported endpoint host with the host from the endpoint URI.

false

MEDIUM

camel.source.endpoint.productUri

The product URI

"http://camel.apache.org/EclipseMilo"

MEDIUM

camel.source.endpoint.requestedPublishingInterval

The requested publishing interval in milliseconds

"1_000.0"

MEDIUM

camel.source.endpoint.requestTimeout

Request timeout in milliseconds

null

MEDIUM

camel.source.endpoint.sessionName

Session name

null

MEDIUM

camel.source.endpoint.sessionTimeout

Session timeout in milliseconds

null

MEDIUM

camel.component.milo-client.clientId

A virtual client id to force the creation of a new connection instance

null

MEDIUM

camel.component.milo-client.configuration

All default options for client configurations

null

MEDIUM

camel.component.milo-client.discoveryEndpoint Suffix

A suffix for endpoint URI when discovering

null

MEDIUM

camel.component.milo-client.discoveryEndpointUri

An alternative discovery URI

null

MEDIUM

camel.component.milo-client.bridgeErrorHandler

Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.

false

MEDIUM

camel.component.milo-client.basicPropertyBinding

Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities

false

MEDIUM

camel.component.milo-client.allowedSecurity Policies

A set of allowed security policy URIs. Default is to accept all and use the highest.

null

MEDIUM

camel.component.milo-client.applicationName

The application name

"Apache Camel adapter for Eclipse Milo"

MEDIUM

camel.component.milo-client.applicationUri

The application URI

"http://camel.apache.org/EclipseMilo/Client"

MEDIUM

camel.component.milo-client.channelLifetime

Channel lifetime in milliseconds

null

MEDIUM

camel.component.milo-client.keyAlias

The name of the key in the keystore file

null

MEDIUM

camel.component.milo-client.keyPassword

The key password

null

MEDIUM

camel.component.milo-client.keyStorePassword

The keystore password

null

MEDIUM

camel.component.milo-client.keyStoreType

The key store type

null

MEDIUM

camel.component.milo-client.keyStoreUrl

The URL where the key should be loaded from

null

MEDIUM

camel.component.milo-client.maxPendingPublish Requests

The maximum number of pending publish requests

null

MEDIUM

camel.component.milo-client.maxResponseMessageSize

The maximum number of bytes a response message may have

null

MEDIUM

camel.component.milo-client.overrideHost

Override the server reported endpoint host with the host from the endpoint URI.

false

MEDIUM

camel.component.milo-client.productUri

The product URI

"http://camel.apache.org/EclipseMilo"

MEDIUM

camel.component.milo-client.requestedPublishing Interval

The requested publishing interval in milliseconds

"1_000.0"

MEDIUM

camel.component.milo-client.requestTimeout

Request timeout in milliseconds

null

MEDIUM

camel.component.milo-client.sessionName

Session name

null

MEDIUM

camel.component.milo-client.sessionTimeout

Session timeout in milliseconds

null

MEDIUM

The camel-milo-client sink connector has no converters out of the box.

The camel-milo-client sink connector has no transforms out of the box.

The camel-milo-client sink connector has no aggregation strategies out of the box.