camel-milo-client-kafka-connector sink configuration

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

When using camel-milo-client-kafka-connector as sink 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 sink connector in Kafka connect you’ll need to set the following connector.class

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

The camel-milo-client sink connector supports 54 options, which are listed below.

Name Description Default Priority

camel.sink.path.endpointUri

Required The OPC UA server endpoint.

HIGH

camel.sink.endpoint.clientId

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

MEDIUM

camel.sink.endpoint.dataChangeFilterDeadbandType

Deadband type for MonitorFilterType DataChangeFilter.

"0"

MEDIUM

camel.sink.endpoint.dataChangeFilterDeadbandValue

Deadband value for MonitorFilterType DataChangeFilter.

"0.0"

MEDIUM

camel.sink.endpoint.dataChangeFilterTrigger

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

Enum values:

  • Status

  • StatusValue

  • StatusValueTimestamp

MEDIUM

camel.sink.endpoint.defaultAwaitWrites

Default await setting for writes.

false

MEDIUM

camel.sink.endpoint.discoveryEndpointSuffix

A suffix for endpoint URI when discovering.

MEDIUM

camel.sink.endpoint.discoveryEndpointUri

An alternative discovery URI.

MEDIUM

camel.sink.endpoint.method

The method definition (see Method ID).

MEDIUM

camel.sink.endpoint.monitorFilterType

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

Enum values:

  • dataChangeFilter

MEDIUM

camel.sink.endpoint.node

The node definition (see Node ID).

MEDIUM

camel.sink.endpoint.samplingInterval

The sampling interval in milliseconds.

"0.0"

MEDIUM

camel.sink.endpoint.lazyStartProducer

Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel’s routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.

false

MEDIUM

camel.sink.endpoint.allowedSecurityPolicies

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

MEDIUM

camel.sink.endpoint.applicationName

The application name.

"Apache Camel adapter for Eclipse Milo"

MEDIUM

camel.sink.endpoint.applicationUri

The application URI.

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

MEDIUM

camel.sink.endpoint.channelLifetime

Channel lifetime in milliseconds.

MEDIUM

camel.sink.endpoint.keyAlias

The name of the key in the keystore file.

MEDIUM

camel.sink.endpoint.keyPassword

The key password.

MEDIUM

camel.sink.endpoint.keyStorePassword

The keystore password.

MEDIUM

camel.sink.endpoint.keyStoreType

The key store type.

MEDIUM

camel.sink.endpoint.keyStoreUrl

The URL where the key should be loaded from.

MEDIUM

camel.sink.endpoint.maxPendingPublishRequests

The maximum number of pending publish requests.

MEDIUM

camel.sink.endpoint.maxResponseMessageSize

The maximum number of bytes a response message may have.

MEDIUM

camel.sink.endpoint.overrideHost

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

false

MEDIUM

camel.sink.endpoint.productUri

The product URI.

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

MEDIUM

camel.sink.endpoint.requestedPublishingInterval

The requested publishing interval in milliseconds.

"1_000.0"

MEDIUM

camel.sink.endpoint.requestTimeout

Request timeout in milliseconds.

MEDIUM

camel.sink.endpoint.sessionName

Session name.

MEDIUM

camel.sink.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.lazyStartProducer

Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel’s routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.

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

Back to top