1.背景

之前获取消费者订阅关系使用的是kafka本身的脚本，易用性较差，获取完数据之后需要大量的人工处理才能整理出关心数据

2.工具：

consumer-groups-get-utils.tar.gz

sh 0-run-all.sh kafka地址即可

结果文件格式：

successGroupConsumerYYYY-XX-XX-XX-XX-XX.txt

YYYY-XX-XX-XX-XX-XX为生成结果文件的时间

结果示例如下

MQ_GROUP_TAXI_CONSUMER:transfer_affirm_topic:10.0.10.46:taxi:vpc-dev26:啦啦啦
ceeu-order:BOC_EVENT_START_SERVICE:10.0.10.55:taxi:vpc-dev26:啦啦啦

组名:topic:ip:业务线:机器名:专家负责人

3.优化点

ipconvert中java程序为  中的 ipconvert

• 其中的ip跟业务线之间的映射json为内部写死的json，可以改造成cmdb接口进行获取，数据为json串，格式为

[{"machine":"prod-center-car","ip":"10.24.24.60","business":"car-insurance"},...]

• 其中业务线跟技术专家之间的映射为内部写死的json，可以改造成cmdb接口进行获取，数据为json串，格式为

[{"business":"ump-marketing","owner":"倪大红"},...]