Commit a90bd316bbec3cbaf7570e343bce7049057cca14
Merge branch 'ww-dev' into 'main'
fix: 修复数据流转Kafka属性保存类型错误 See merge request yunteng/thingskit-front!519
Showing
1 changed file
with
2 additions
and
1 deletions
| ... | ... | @@ -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') { | ... | ... |