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:
Log in to the IoT Hub console and click Rule Engine on the left sidebar.
Go to the rule engine page and click the rule to be configured.
On the rule details page, click Add Action.
You will be prompted to authorize access to CKafka upon the first use. You need to click Authorize Now before you can proceed.
In the Add Action pop-up window, select Forward data to CKafka, CKafka instance, and topic and click Save.
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.
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: