炫意html5
最早CSS3和HTML5移动技术网站之一

kafka 中数据写入SQLserver中,不写程序。

现在本地测试MySQL写入kafka中,kafka写入SQLserver中是可以的。这个主要是MySQL写入进去的数据是带有结构的:比如下面的kafka中的数据就可以写入SQLserver中:

{
“schema”: {
“type”: “struct”,
“fields”: [
{
“type”: “int64”,
“optional”: false,
“field”: “id”
},
{
“type”: “string”,
“optional”: false,
“field”: “value”
},
{
“type”: “int32”,
“optional”: true,
“name”: “org.apache.kafka.connect.data.Date”,
“version”: 1,
“field”: “createDate”
}
],
“optional”: false,
“name”: “delay_quote”
},
“payload”: {
“id”: 6,
“value”: “006”,
“createDate”: 18885
}
}

但是现在kafka中的数据是这样的,没有带结构而是json:

{
“Temperature”: 0.65,
“timestamp”: 1631778297000
}

如果我不想写程序将这种json数据写入数据库中,这种可以实现吗?如果可以实现消费者里面如何配置呢?
请教大佬解惑:

回答

经过调查,这种情况没法用配置完成,只能写程序进行kafka写入db。

炫意HTML5 » kafka 中数据写入SQLserver中,不写程序。

Java基础教程Android基础教程