问题描述
我对 Node 和 Kafka 开发很陌生。我正在构建一个需要向 kafka 生成消息的服务，同时还需要使用来自另一个主题的消息。对于消费，我使用的是消费者流 API。
不过，为了生成消息，我试图找出基本上有一个后台线程来监视填充了需要发送的消息的列表。该列表将根据使用的数据填充数据。
查看用于生产的 Standard API，我发现我需要监听“就绪”事件。但是，在就绪事件之后我应该启动/启动什么后台进程？我想要一个进程/线程轮询需要发送的消息队列/列表，并发送它们，并不断检查是否还有更多消息要发送。
工作线程在这里合适吗？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）