tencent cloud

Overview

The rule engine allows you to configure rules to forward eligible data reported by devices to CKafka, and then your application server can read the data from CKafka for processing. This takes advantage of CKafka's high throughput to create a highly available message linkage.

The figure below shows the entire process of forwarding data to CKafka by the rule engine:

Configuration

1. Log in to the IoT Hub console and click Rule Engine on the left sidebar.

2. Go to the rule engine page and click the rule to be configured.

3. On the rule details page, click Add Action.

   Note：

   You will be prompted to authorize access to CKafka upon the first use. You need to click Authorize Now before you can proceed.

4. In the Add Action pop-up window, select Forward data to CKafka, CKafka instance, and topic and click Save.
   

5. After the above configuration is completed, IoT Hub will forward eligible data reported by devices to the configured CKafka instance. You can refer to Process Overview to read and process the data on your own application server.

Resending Mechanism

The resending mechanism is used to send the message again in case of a failure in the message forwarding process, which makes sure that the message is received. The details are as follows:

• If message forwarding fails, the system will retry forwarding at intervals of 1s, 3s, and 10s in sequence. If all three retries fail, the message will be discarded.
• If you have configured the forward error action, then after three unsuccessful retries, the message will be forwarded again according to the configured action. If forwarding still fails, the message will be discarded.