增强
添加了对 Confluent 数据桥的支持。
现在 Kafka 消费组里的 MQTT 主题字段支持包含占位符的模板。
比如 Kafka 消费到消息里 key 为 "a",配置的 MQTT 主题为 "topic/${key}",那么在消息转发的时,MQTT 主题会被替换为 "topic/a"。
现在 “消息重发布” 动作支持添加 “MQTT 属性” 和 “用户属性”。
“消息重发布” 动作支持两个新的字段:"MQTT 属性" 和 "用户属性",都是键值对的格式,并且键和值都支持占位符。
修复
修复 Kafka 动作无法将数字类型的值作为 Kafka Headers 发送的问题。
修复之前,当 “Kafka Headers 值的编码类型” 设置为 "NONE" 的情况下,如果 "Kafka Headers" 字段里包含了带有数字类型的 JSON 对象(比如
{"a": 1, "b": "str"}
),数字类型的值("a":1
)将会被忽略,不会被发送到 Kafka。修复之后 JSON 中的数字类型会先转换为字符串再发送到 Kafka。