如何从Javascript执行Kafka消费者文件

rta7y2nd 于 2022-11-21 发布在 Apache

关注(0)|答案(1)|浏览(155)

我已经使用了KafkaJS库并配置了一个消费者代码来从我的一个流API的主题中获取消息。
我已经创建了一个consumer.js文件，并且可以使用node consumer.js从命令行中的位置运行该文件
但是我的要求是从我的javascript/cypress代码中执行consumer.js文件。我已经将完整的consumer.js代码放在一个类下的一个方法中，并试图调用，但它失败了。
有没有办法直接从代码中运行node consumer.js命令，或者我如何从我的类中调用它。
已尝试类似于此https://thecodebarbarian.com/getting-started-with-apache-kafka-in-node-js.html的使用者代码
任何帮助都将不胜感激。
谢谢

apache-kafka

来源：https://stackoverflow.com/questions/72144054/how-to-execute-the-kafka-consumer-file-from-javascript

1条答案

按热度按时间

6qftjkof1#

cy.exec()允许执行系统命令。**注：**需要考虑一些奇怪的事情，这些事情并不明显，可能会导致无法解释的行为。

cy.exec('node consumer.js')
  // may be worthwhile to assert that the file ran successfully
  .its('code')
  .should('equal', 0);

赞(0）回复(0）举报 2022-11-21

我来回答

如何从Javascript执行Kafka消费者文件

1条答案

相关问题

热门标签

最新问答