优化gohangout处理线程数,增加处理能力。 1:修改gohangout配置 登录10.224.11.35 cd /data/tsg/olap/galaxy/volumes/gohangout/bin/ghoStart vim start_gohangout_k2ck_session_record_tsgv3.sh 将THREAD_SUM的值修改为6 保存后,将start_gohangout_k2ck_session_record_tsgv3.sh文件分发到 10.224.11.36-49 同目录下 2:重启gohangout 依次登录10.224.11.35-49 2.1: cd /data/tsg/olap/galaxy/workspace/gohangout docker-compose down 校验:docker ps -a | grep gohangout 没有结果即已关闭,若还有结果则等待一分钟再执行一次。 若还存在,则执行docker rm -f gohangout 2.2: docker-compose up -d 校验:docker ps -a | grep gohangout 有对应的结果,且状态为UP 重启后确认: 通过TSG界面查看日志正常。 ----------------------------------------------------------------- 确认日志没有问题后,等待运行20分钟。 1:登录10.224.11.14:9998传回brokers界面。 2:登录10.224.11.14:9998点consumer,搜索session_record_completed_tsgv3,再点topic进去,保存页面。 3:查询该语句,时间范围过去1天。 sum by(asset) (kafka_server_BrokerTopicMetrics_OneMinuteRate{name="MessagesInPerSec",topic="SESSION-RECORD-COMPLETED"})