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



我们,dev,有一个在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

但是为了安全起见,我们的访问被暂停了(开发团队不能再运行上面的命令行了(。infra的人说我们可以试着用詹金斯做同样的任务,所以他们说安全漏洞不会成为问题。

因此,我们需要通过使用jenkins运行的脚本来完成同样的操作(检索挂起的kafka消息(。

有什么帮助吗?

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

  • 创建新项目

  • 在构建部分,选择">执行shell">

  • 输入:

    sshapplicationID@serverName'kafka-consumer-groups.bat--引导服务器server1:port1,server2:p'

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

可以。

最新更新