Posted On: Oct 29, 2023

Today, Amazon IoT Core, a fully managed cloud service that lets you connect billions of devices and process trillions of messages, supports headers in Rules Engine’s Kafka Action. You can use Kafka headers to send additional metadata from IoT devices to a self-managed Apache Kafka cluster or Amazon Managed Streaming for Apache Kafka (Amazon MSK), without modifying the original IoT message payload. 

Kafka Action is a feature in Amazon IoT Core’s Rules Engine that enables you to route your IoT messages to Kafka clusters. With the new feature, you can pass additional meta-data, such as a timestamp, source IP address of the publisher of an IoT message, and MQTT user properties to Kafka clusters using only headers, simplifying your developer experience by eliminating the need to embed such metadata into the actual payload. To get started, connect your IoT devices to Amazon IoT Core, define an IoT Rule and a Kafka Action to route the IoT message to your Kafka cluster. 

Amazon IoT Core’s support for headers in Kafka Action is available in Amazon Web Services China (Beijing) Region, operated by Sinnet, and Amazon Web Services China (Ningxia) Region, operated by NWCD.

For more information, refer to the developer guide.