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 52 options, which are listed below.

Name	Description	Default	Required	Priority
camel.source.path.endpointUri	The OPC UA server endpoint	null	true	HIGH
camel.source.endpoint.clientId	A virtual client id to force the creation of a new connection instance	null	false	MEDIUM
camel.source.endpoint.defaultAwaitWrites	Default await setting for writes	false	false	MEDIUM
camel.source.endpoint.discoveryEndpointSuffix	A suffix for endpoint URI when discovering	null	false	MEDIUM
camel.source.endpoint.discoveryEndpointUri	An alternative discovery URI	null	false	MEDIUM
camel.source.endpoint.method	The method definition (see Method ID)	null	false	MEDIUM
camel.source.endpoint.node	The node definition (see Node ID)	null	false	MEDIUM
camel.source.endpoint.samplingInterval	The sampling interval in milliseconds	"0.0"	false	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	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	false	MEDIUM
camel.source.endpoint.exchangePattern	Sets the exchange pattern when the consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut]	null	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	false	MEDIUM
camel.source.endpoint.allowedSecurityPolicies	A set of allowed security policy URIs. Default is to accept all and use the highest.	null	false	MEDIUM
camel.source.endpoint.applicationName	The application name	"Apache Camel adapter for Eclipse Milo"	false	MEDIUM
camel.source.endpoint.applicationUri	The application URI	"http://camel.apache.org/EclipseMilo/Client"	false	MEDIUM
camel.source.endpoint.channelLifetime	Channel lifetime in milliseconds	null	false	MEDIUM
camel.source.endpoint.keyAlias	The name of the key in the keystore file	null	false	MEDIUM
camel.source.endpoint.keyPassword	The key password	null	false	MEDIUM
camel.source.endpoint.keyStorePassword	The keystore password	null	false	MEDIUM
camel.source.endpoint.keyStoreType	The key store type	null	false	MEDIUM
camel.source.endpoint.keyStoreUrl	The URL where the key should be loaded from	null	false	MEDIUM
camel.source.endpoint.maxPendingPublishRequests	The maximum number of pending publish requests	null	false	MEDIUM
camel.source.endpoint.maxResponseMessageSize	The maximum number of bytes a response message may have	null	false	MEDIUM
camel.source.endpoint.overrideHost	Override the server reported endpoint host with the host from the endpoint URI.	false	false	MEDIUM
camel.source.endpoint.productUri	The product URI	"http://camel.apache.org/EclipseMilo"	false	MEDIUM
camel.source.endpoint.requestedPublishingInterval	The requested publishing interval in milliseconds	"1_000.0"	false	MEDIUM
camel.source.endpoint.requestTimeout	Request timeout in milliseconds	null	false	MEDIUM
camel.source.endpoint.sessionName	Session name	null	false	MEDIUM
camel.source.endpoint.sessionTimeout	Session timeout in milliseconds	null	false	MEDIUM
camel.component.milo-client.clientId	A virtual client id to force the creation of a new connection instance	null	false	MEDIUM
camel.component.milo-client.configuration	All default options for client configurations	null	false	MEDIUM
camel.component.milo-client.discoveryEndpoint Suffix	A suffix for endpoint URI when discovering	null	false	MEDIUM
camel.component.milo-client.discoveryEndpointUri	An alternative discovery URI	null	false	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	false	MEDIUM
camel.component.milo-client.autowiredEnabled	Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.	true	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	false	MEDIUM
camel.component.milo-client.applicationName	The application name	"Apache Camel adapter for Eclipse Milo"	false	MEDIUM
camel.component.milo-client.applicationUri	The application URI	"http://camel.apache.org/EclipseMilo/Client"	false	MEDIUM
camel.component.milo-client.channelLifetime	Channel lifetime in milliseconds	null	false	MEDIUM
camel.component.milo-client.keyAlias	The name of the key in the keystore file	null	false	MEDIUM
camel.component.milo-client.keyPassword	The key password	null	false	MEDIUM
camel.component.milo-client.keyStorePassword	The keystore password	null	false	MEDIUM
camel.component.milo-client.keyStoreType	The key store type	null	false	MEDIUM
camel.component.milo-client.keyStoreUrl	The URL where the key should be loaded from	null	false	MEDIUM
camel.component.milo-client.maxPendingPublish Requests	The maximum number of pending publish requests	null	false	MEDIUM
camel.component.milo-client.maxResponseMessageSize	The maximum number of bytes a response message may have	null	false	MEDIUM
camel.component.milo-client.overrideHost	Override the server reported endpoint host with the host from the endpoint URI.	false	false	MEDIUM
camel.component.milo-client.productUri	The product URI	"http://camel.apache.org/EclipseMilo"	false	MEDIUM
camel.component.milo-client.requestedPublishing Interval	The requested publishing interval in milliseconds	"1_000.0"	false	MEDIUM
camel.component.milo-client.requestTimeout	Request timeout in milliseconds	null	false	MEDIUM
camel.component.milo-client.sessionName	Session name	null	false	MEDIUM
camel.component.milo-client.sessionTimeout	Session timeout in milliseconds	null	false	MEDIUM

Name

Description

Default

Required

Priority

camel.source.path.endpointUri

The OPC UA server endpoint

null

true

HIGH

camel.source.endpoint.clientId

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

null

false

MEDIUM

camel.source.endpoint.defaultAwaitWrites

Default await setting for writes

false

MEDIUM

camel.source.endpoint.discoveryEndpointSuffix

A suffix for endpoint URI when discovering

null

false

MEDIUM

camel.source.endpoint.discoveryEndpointUri

An alternative discovery URI

null

false

MEDIUM

camel.source.endpoint.method

The method definition (see Method ID)

null

false

MEDIUM

camel.source.endpoint.node

The node definition (see Node ID)

null

false

MEDIUM

camel.source.endpoint.samplingInterval

The sampling interval in milliseconds

"0.0"

false

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

false

MEDIUM

camel.source.endpoint.exchangePattern

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

null

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

false

MEDIUM

camel.source.endpoint.applicationName

The application name

"Apache Camel adapter for Eclipse Milo"

false

MEDIUM

camel.source.endpoint.applicationUri

The application URI

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

false

MEDIUM

camel.source.endpoint.channelLifetime

Channel lifetime in milliseconds

null

false

MEDIUM

camel.source.endpoint.keyAlias

The name of the key in the keystore file

null

false

MEDIUM

camel.source.endpoint.keyPassword

The key password

null

false

MEDIUM

camel.source.endpoint.keyStorePassword

The keystore password

null

false

MEDIUM

camel.source.endpoint.keyStoreType

The key store type

null

false

MEDIUM

camel.source.endpoint.keyStoreUrl

The URL where the key should be loaded from

null

false

MEDIUM

camel.source.endpoint.maxPendingPublishRequests

The maximum number of pending publish requests

null

false

MEDIUM

camel.source.endpoint.maxResponseMessageSize

The maximum number of bytes a response message may have

null

false

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"

false

MEDIUM

camel.source.endpoint.requestedPublishingInterval

The requested publishing interval in milliseconds

"1_000.0"

false

MEDIUM

camel.source.endpoint.requestTimeout

Request timeout in milliseconds

null

false

MEDIUM

camel.source.endpoint.sessionName

Session name

null

false

MEDIUM

camel.source.endpoint.sessionTimeout

Session timeout in milliseconds

null

false

MEDIUM

camel.component.milo-client.clientId

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

null

false

MEDIUM

camel.component.milo-client.configuration

All default options for client configurations

null

false

MEDIUM

camel.component.milo-client.discoveryEndpoint Suffix

A suffix for endpoint URI when discovering

null

false

MEDIUM

camel.component.milo-client.discoveryEndpointUri

An alternative discovery URI

null

false

MEDIUM

camel.component.milo-client.bridgeErrorHandler

false

MEDIUM

camel.component.milo-client.autowiredEnabled

Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.

true

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

false

MEDIUM

camel.component.milo-client.applicationName

The application name

"Apache Camel adapter for Eclipse Milo"

false

MEDIUM

camel.component.milo-client.applicationUri

The application URI

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

false

MEDIUM

camel.component.milo-client.channelLifetime

Channel lifetime in milliseconds

null

false

MEDIUM

camel.component.milo-client.keyAlias

The name of the key in the keystore file

null

false

MEDIUM

camel.component.milo-client.keyPassword

The key password

null

false

MEDIUM

camel.component.milo-client.keyStorePassword

The keystore password

null

false

MEDIUM

camel.component.milo-client.keyStoreType

The key store type

null

false

MEDIUM

camel.component.milo-client.keyStoreUrl

The URL where the key should be loaded from

null

false

MEDIUM

camel.component.milo-client.maxPendingPublish Requests

The maximum number of pending publish requests

null

false

MEDIUM

camel.component.milo-client.maxResponseMessageSize

The maximum number of bytes a response message may have

null

false

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"

false

MEDIUM

camel.component.milo-client.requestedPublishing Interval

The requested publishing interval in milliseconds

"1_000.0"

false

MEDIUM

camel.component.milo-client.requestTimeout

Request timeout in milliseconds

null

false

MEDIUM

camel.component.milo-client.sessionName

Session name

null

false

MEDIUM

camel.component.milo-client.sessionTimeout

Session timeout in milliseconds

null

false

MEDIUM

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

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

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