我对 Node 和 Kafka 开发还很陌生。我正在构建一个需要向 kafka 生成消息的服务，同时还要使用来自另一个主题的消息。对于消费，我使用的是消费者流 API。
不过，为了生成消息，我试图弄清楚基本上有一个后台线程来监视一个列表，该列表中填充了需要发送的消息。该列表将根据使用的数据填充数据。
查看用于生产的标准 API，我发现我需要监听“就绪”事件。但是，在准备好的事件之后，我应该启动/启动什么后台进程？我想要一个进程/线程来轮询需要发送的消息队列/列表，并发送它们，并不断检查是否还有更多消息要发送。
工作线程在这里合适吗？