Microservice-based data broker

Using the microservice-based data broker

The microservice-based data broker is powered by the Cumulocity IoT Messaging Service that enables reliable, scalable and high-performance movement of IoT data. The microservice-based data broker is similar to the existing data broker in its functionality, except that a microservice, the databroker-agent-server, must be enabled to make use of it.

Requirements

The Cumulocity IoT Messaging Service is an optional component of the Cumulocity IoT platform that may need to be enabled before the microservice-based data broker can be used. The original data broker will continue to operate alongside the microservice-based data broker for the time being, and users can choose which data broker to use on a per-tenant basis.

For the shared public cloud instances of the Cumulocity IoT platform, the Messaging Service is enabled by default on release 10.13 and above, and the microservice-based data broker can be enabled on request for individual tenants that already have access to the original data broker. For dedicated and self-hosted instances, the Messaging Service and microservice-based data broker are available for release 10.10 and above, but will need to be explicitly enabled.

Please contact product support to inquire about using the Messaging Service and microservice-based data broker capabilities in your Cumulocity IoT environment. See the Messaging Service - Installation & operations guide for further technical details of the configuration required, but note that these tasks can only be performed by a Cumulocity IoT platform operator, not by a normal user.

In summary, to work with the microservice-based data broker, the following requirements must be met:

  • The Cumulocity IoT Messaging Service should be available on your Cumulocity IoT platform.
  • Your tenant must be subscribed to the application “feature-broker”.
  • Your tenant must be subscribed to the microservice “databroker-agent-server”.

To enable the microservice-based data broker

The microservice-based data broker must be enabled from the Management tenant. Contact your Operations team for further support.

Data connectors

See Data connectors for details on how to manage data connectors.

Data subscriptions

See Data subscriptions for details on how to manage data subscriptions.

Migrating existing data connectors to the microservice-based data broker

After enabling the microservice-based data broker, your existing data connectors should continue to work without any additional configuration.

Troubleshooting

Subscription alert

The Management tenant cannot be used as a data broker source tenant and this alarm is raised when trying to subscribe a Management tenant to the data broker agent.

Data broker connection error

The data broker agent is pre-configured to monitor each connector for the number of failed forwarding requests sent. If this number reaches a pre-configured threshold a CRITICAL alarm is raised in the tenant. If this happens the data will be stored until the connection is restored and it can be forwarded again. Failed requests can happen in the event the data broker subscriber tenant becomes unreachable.

Data broker slow processing alert

The data broker agent is pre-configured to monitor the rate at which events are being delivered to their destination. If events cannot be delivered fast enough, slow processing alarms will be raised. A slow processing alarm includes a connector ID to help identify which destination tenant is affected.

Queue backlog

This alarm is raised when latency for message delivery crosses a specified threshold. This usually happens if there is a backlog of undelivered events to the destination tenant due to various factors.

Average request bytes sent per second

The data broker monitors the data rate at which events are being forwarded. If this rate is lower than a pre-configured threshold, a slow processing alert will be raised. This can occur due to a slow network.

New Data-Broker Alarms

Info
Refer to the Messaging Service Installation & operations guide to find out more about how these parameters can be configured.