我们dev有一个在hadoop环境中运行的kafka队列（v2.11-0.10.2.1）的使用者。
我们可以使用以下命令从队列中检索挂起的消息（kafka在每个dev计算机中本地运行）：
kafka-consumer-groups.bat --bootstrap-server server1:port1,server2:port2,server3:port3,server4:port4 --describe --group simple-csharp-consumer但是为了安全起见，我们的访问被暂停了（开发团队不能再运行上面的命令行）。infra的人说我们可以用jenkins做同样的任务，这样安全漏洞就不会是问题了。
因此，我们需要帮助通过运行jenkins的脚本执行相同的操作（检索挂起的kafka消息）。
有什么帮助吗？
1条答案
按热度按时间ia2d9nvy1#
假设您的infra团队已经在jenkins和hadoop服务器之间建立了连接，
创建新项目
在build部分，选择executeshell。
输入以下内容：
宋承宪applicationid@servername 'kafka-consumer-groups.bat--引导服务器server1:port1，server2:p'
单击“保存”。那现在就建吧。
就行了。