kafka消费者桥接 消息过期间隔时间 如何设置

EMQX
,
1

EMQX 版本：v5.2.0

关于kafka 消费者桥接

当前已经实现了消息转发，我想要为桥接的消息添加系统参数，
例如 message_expiry_interval ，消息过期间隔时间，该如何操作

2

这个参数是 Kafka 的功能吗，我没见过 Kafka 有消息过期的功能。

如果你是想把 MQTT 5.0 消息里的 Message-Expiry-Interval 属性作为 Kafka Value 或者 Headers 发送到 Kafka，现在已经有了。你可以通过规则获取 Message-Expiry-Interval 的值，然后在 Kafka 动作里面填写响应的值：

SELECT pub_props.'Message-Expiry-Interval' as message_expiry_interval, payload

然后在 Kafka 消息的模板里面：

exp: ${message_expiry_interval}, payload: ${payload}