camel-milo-client-kafka-connector source configuration

Connector Description: Connect to OPC UA servers using the binary protocol for acquiring telemetry data.

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

Name Description Default Priority

camel.source.path.endpointUri

Required The OPC UA server endpoint.

HIGH

camel.source.endpoint.clientId

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

MEDIUM

camel.source.endpoint.dataChangeFilterDeadbandType

Deadband type for MonitorFilterType DataChangeFilter.

"0"

MEDIUM

camel.source.endpoint.dataChangeFilterDeadbandValue

Deadband value for MonitorFilterType DataChangeFilter.

"0.0"

MEDIUM

camel.source.endpoint.dataChangeFilterTrigger

Daata change trigger for data change monitor filter type. One of: [Status] [StatusValue] [StatusValueTimestamp].

Enum values:

  • Status

  • StatusValue

  • StatusValueTimestamp

MEDIUM

camel.source.endpoint.defaultAwaitWrites

Default await setting for writes.

false

MEDIUM

camel.source.endpoint.discoveryEndpointSuffix

A suffix for endpoint URI when discovering.

MEDIUM

camel.source.endpoint.discoveryEndpointUri

An alternative discovery URI.

MEDIUM

camel.source.endpoint.method

The method definition (see Method ID).

MEDIUM

camel.source.endpoint.monitorFilterType

Monitor Filter Type for MonitoredItems. One of: [dataChangeFilter].

Enum values:

  • dataChangeFilter

MEDIUM

camel.source.endpoint.node

The node definition (see Node ID).

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.

MEDIUM

camel.source.endpoint.exchangePattern

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

Enum values:

  • InOnly

  • InOut

  • InOptionalOut

MEDIUM

camel.source.endpoint.allowedSecurityPolicies

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

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.

MEDIUM

camel.source.endpoint.keyAlias

The name of the key in the keystore file.

MEDIUM

camel.source.endpoint.keyPassword

The key password.

MEDIUM

camel.source.endpoint.keyStorePassword

The keystore password.

MEDIUM

camel.source.endpoint.keyStoreType

The key store type.

MEDIUM

camel.source.endpoint.keyStoreUrl

The URL where the key should be loaded from.

MEDIUM

camel.source.endpoint.maxPendingPublishRequests

The maximum number of pending publish requests.

MEDIUM

camel.source.endpoint.maxResponseMessageSize

The maximum number of bytes a response message may have.

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.

MEDIUM

camel.source.endpoint.sessionName

Session name.

MEDIUM

camel.source.endpoint.sessionTimeout

Session timeout in milliseconds.

MEDIUM

camel.component.milo-client.clientId

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

MEDIUM

camel.component.milo-client.configuration

All default options for client configurations.

MEDIUM

camel.component.milo-client.discoveryEndpointSuffix

A suffix for endpoint URI when discovering.

MEDIUM

camel.component.milo-client.discoveryEndpointUri

An alternative discovery URI.

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.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

MEDIUM

camel.component.milo-client.allowedSecurityPolicies

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

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.

MEDIUM

camel.component.milo-client.keyAlias

The name of the key in the keystore file.

MEDIUM

camel.component.milo-client.keyPassword

The key password.

MEDIUM

camel.component.milo-client.keyStorePassword

The keystore password.

MEDIUM

camel.component.milo-client.keyStoreType

The key store type.

MEDIUM

camel.component.milo-client.keyStoreUrl

The URL where the key should be loaded from.

MEDIUM

camel.component.milo-client.maxPendingPublishRequests

The maximum number of pending publish requests.

MEDIUM

camel.component.milo-client.maxResponseMessageSize

The maximum number of bytes a response message may have.

MEDIUM

camel.component.milo-client.miloClientConnectionManager

Instance for managing client connections.

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.requestedPublishingInterval

The requested publishing interval in milliseconds.

"1_000.0"

MEDIUM

camel.component.milo-client.requestTimeout

Request timeout in milliseconds.

MEDIUM

camel.component.milo-client.sessionName

Session name.

MEDIUM

camel.component.milo-client.sessionTimeout

Session timeout in milliseconds.

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.

Back to top