node.js - 使用 kafkajs 的 RequestReply 模式

Question

我有一个问题，无法自己解决，所以寻求帮助。所以我要实现基于kafkajs的同步请求-回复模式。这是一个简短的原型：gist code

我在第二次迭代（嵌套承诺）时遇到了问题，eventEmitter 使用旧对象并且无法解决承诺。将不胜感激任何想法。