如何解决kafka流未从平面映射值向dlq主题生成消息
const Bull = require('bull');
// This looks for a Redis server running at port 6379 on your local machine by default
const jobQueue = new Bull("my_job_queue")
app.post("/doSomething",(req,res) => {
const { taskObj } = req.body;
// This is non blocking
jobQueue.add(taskObj);
// Then,just return
res.status(200).json({
"message": "We're on it!","something else": "We'll get back to you soon :)"
});
});
jobQueue.process((job,done) => {
// This runs per job
const doSomething = (jobData) => {
return new Promise((resolve,reject) => {
console.log(JSON.stringify(jobData));
resolve(true);
})
}
const { data } = job;
await doSomething(data);
// Wait to finish doing something with the data,and then move on
done();
});
如果有效方法(v)中发生异常,它将关闭kafka流。但是,如果我停止从catch块生成dlq主题,它会正常工作。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。