时间戳

首页 > 解决方案 > 通过 jenkins 从 kafka 队列中检索消息数

jenkins - 通过 jenkins 从 kafka 队列中检索消息数

问题描述

我们，开发者，有一个在 hadoop 环境中运行的 kafka 队列（v2.11-0.10.2.1）的消费者。

我们可以使用以下命令从队列中检索待处理的消息（kafka 在每台开发计算机上本地运行）：

kafka-consumer-groups.bat --bootstrap-server server1:port1,server2:port2,server3:port3,server4:port4 --describe --group simple-csharp-consumer

但是为了安全起见，我们的访问已经被暂停（开发团队不能再运行上面的命令行了）。基础设施人员说我们可以尝试使用 jenkins 执行相同的任务，因此他们说安全漏洞不会成为问题。

因此，我们需要帮助通过使用 jenkins 运行的脚本来执行相同的操作（检索待处理的 kafka 消息）。

有什么帮助吗？

标签： jenkinsapache-kafka

解决方案

假设您的基础设施团队已经在 jenkins 和 hadoop 服务器之间建立了连接，

  • 创建一个新项目

  • 在构建部分中，选择“执行 shell”。

  • 输入这个：

    ssh applicationID@serverName 'kafka-consumer-groups.bat --bootstrap-server server1:port1,server2:p'

  • 单击保存。然后立即构建。

会的。

推荐阅读