fix(docs):uncomment nodejs tmq example's commit
This commit is contained in:
parent
1a5ae2bfdf
commit
452395bc46
|
@ -28,8 +28,7 @@ function runConsumer() {
|
||||||
console.log(msg.topicPartition);
|
console.log(msg.topicPartition);
|
||||||
console.log(msg.block);
|
console.log(msg.block);
|
||||||
console.log(msg.fields)
|
console.log(msg.fields)
|
||||||
// fixme(@xiaolei): commented temp, should be fixed.
|
consumer.commit(msg);
|
||||||
//consumer.commit(msg);
|
|
||||||
console.log(`=======consumer ${i} done`)
|
console.log(`=======consumer ${i} done`)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -4,7 +4,7 @@
|
||||||
"main": "index.js",
|
"main": "index.js",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@tdengine/client": "^3.0.0",
|
"@tdengine/client": "^3.0.1",
|
||||||
"@tdengine/rest": "^3.0.0"
|
"@tdengine/rest": "^3.0.0"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue