我们,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'
-
单击保存。然后立即构建。
可以。