Commit d3595d5b3a9304c6ac869c0fe179e09ecd0b74fe

Authored by ww
1 parent e554bc96

fix: 修复数据流转Kafka属性保存类型错误

... ... @@ -269,7 +269,6 @@
269 269 const type = Reflect.get(record, 'type');
270 270 const configuration = Reflect.get(record, 'configuration');
271 271 const clientProperties = Reflect.get(configuration, 'clientProperties');
272   - console.log(clientProperties);
273 272 !clientProperties && (record.configuration.clientProperties = {});
274 273
275 274 if (
... ... @@ -281,7 +280,9 @@
281 280 }
282 281
283 282 if (type === 'org.thingsboard.rule.engine.kafka.TbKafkaNode') {
  283 + const otherProperties = Reflect.get(configuration, 'otherProperties');
284 284 configuration.kafkaHeadersCharset = 'UTF-8';
  285 + !otherProperties && (record.configuration.otherProperties = {});
285 286 }
286 287
287 288 if (type === 'org.thingsboard.rule.engine.rabbitmq.TbRabbitMqNode') {
... ...