#list response.result as consumerProgressVO>
<#assign row = RequestParameters.begin?number + consumerProgressVO_index + 1>
${row} |
onclick="getQueueOwner('${consumerProgressVO.consumer.name}', '${consumerProgressVO.consumer.id}')"#if>>${consumerProgressVO.consumer.name} |
<#if consumerProgressVO.ownerList??>
<#if consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1>
<#list consumerProgressVO.ownerList as user>
<#if user_index != 0>
,
#if>
${user.name!user.getEmailName()}
#list>
<#else>
<#list consumerProgressVO.ownerList as user>
<#if user_index != 0>
,
#if>
${user.name!user.getEmailName()}
#list>
#if>
|
<#else>
暂无 |
#if>
data-toggle="tooltip" title="${consumerProgressVO.consumer.info}"#if>>
<#if consumerProgressVO.consumer.info?? && consumerProgressVO.consumer.info?length gt 12>
<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>${consumerProgressVO.consumer.info?substring(0,12)}...<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>
<#else>
<#if consumerProgressVO.consumer.info?? && consumerProgressVO.consumer.info !=''>
<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>${consumerProgressVO.consumer.info}<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>
<#else>
<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>
#if>
#if>
#if>
|
集群 |
${consumerProgressVO.diff} |
${consumerProgressVO.consumeTpsFormat} |
<#if topic.traceEnabled()>
<#if (consumerProgressVO.ownerList?? && consumerProgressVO.ownerList?seq_contains(userInfo.user)) || userInfo.user.type == 1>
<#if consumerProgressVO.consumer.traceEnabled()>
<#else>
#if>
<#else>
<#if consumerProgressVO.consumer.traceEnabled()><#else>#if>
#if>
<#else>
#if>
|
<#if consumerProgressVO.minLastTimestamp == 0>
暂无 |
<#else>
<#if consumerProgressVO.minLastTimestamp == long.MAX_VALUE>
消费进度不存在 |
<#else>
${consumerProgressVO.minLastTimestamp?number_to_datetime?string("yyyy-MM-dd HH:mm:ss")} |
#if>
#if>
<#if (consumerProgressVO.ownerList?? && consumerProgressVO.ownerList?seq_contains(userInfo.user)) || userInfo.user.type == 1>
<#if consumerProgressVO.offsetMap??>
#if>
#if>
<#if consumerProgressVO.offsetMap??>
<#if consumerProgressVO.dlqTopic?? && consumerProgressVO.dlqOffsetMap??>
死消息Topic:${consumerProgressVO.dlqTopic}
|
broker |
队列 |
最小偏移量 |
最大偏移量 |
消息量 |
更新时间 |
<#list consumerProgressVO.dlqOffsetMap as k, v>
${k.brokerName} |
${k.queueId} |
${v.minOffset?string(",###")}
|
${v.maxOffset?string(",###")}
|
${v.maxOffset - v.minOffset}
|
<#if v.lastUpdateTimestamp <= 0>
暂无 |
<#else>
${v.lastUpdateTimestamp?number_to_datetime?string("yyyy-MM-dd HH:mm:ss")}
|
#if>
#list>
#if>
<#if consumerProgressVO.retryTopic?? && consumerProgressVO.retryOffsetMap??>
重试Topic:${consumerProgressVO.retryTopic}
|
客户端 |
broker |
队列 |
broker偏移量 |
消费者偏移量 |
堆积量 |
消费到 |
<#list consumerProgressVO.retryOffsetMap as k, v>
|
${k.brokerName} |
${k.queueId} |
${v.brokerOffset?string(",###")}
|
${v.consumerOffset?string(",###")}
|
${v.brokerOffset - v.consumerOffset}
|
<#if v.lastTimestamp <= 0>
暂无 |
<#else>
${v.lastTimestamp?number_to_datetime?string("yyyy-MM-dd HH:mm:ss")}
|
#if>
#list>
#if>
Topic:${consumerProgressVO.topic} |
客户端 |
broker |
队列 |
broker偏移量 |
消费者偏移量 |
堆积量 |
消费到 |
<#list consumerProgressVO.offsetMap as k, v>
|
${k.brokerName} |
${k.queueId} |
${v.brokerOffset?string(",###")}
|
${v.consumerOffset?string(",###")}
|
${v.brokerOffset - v.consumerOffset}
|
<#if v.lastTimestamp <= 0>
暂无 |
<#else>
${v.lastTimestamp?number_to_datetime?string("yyyy-MM-dd HH:mm:ss")}
|
#if>
#list>
#if>
|
#list>
<#list resultExt.result as consumerProgressVO>
<#assign row = RequestParameters.begin?number + consumerProgressVO_index + 1 + response.result?size>
${row} |
${consumerProgressVO.consumer.name} |
<#if consumerProgressVO.ownerList??>
<#if consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1>
<#list consumerProgressVO.ownerList as user>
<#if user_index != 0>
,
#if>
${user.name!user.getEmailName()}
#list>
<#else>
<#list consumerProgressVO.ownerList as user>
<#if user_index != 0>
,
#if>
${user.name!user.getEmailName()}
#list>
#if>
|
<#else>
暂无 |
#if>
data-toggle="tooltip" title="${consumerProgressVO.consumer.info}"#if>>
<#if consumerProgressVO.consumer.info?? && consumerProgressVO.consumer.info?length gt 12>
<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>${consumerProgressVO.consumer.info?substring(0,12)}...<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>
<#else>
<#if consumerProgressVO.consumer.info?? && consumerProgressVO.consumer.info !=''>
<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>${consumerProgressVO.consumer.info}<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>#if>
<#else>
<#if consumerProgressVO.ownerList?? && (consumerProgressVO.ownerList?seq_contains(userInfo.user) || userInfo.user.type == 1)>
#if>
#if>
#if>
|
广播 |
${consumerProgressVO.diff} |
${consumerProgressVO.consumeTpsFormat} |
|
<#if consumerProgressVO.minLastTimestamp == 0>
暂无 |
<#else>
<#if consumerProgressVO.minLastTimestamp == long.MAX_VALUE>
消费进度不存在 |
<#else>
${consumerProgressVO.minLastTimestamp?number_to_datetime?string("yyyy-MM-dd HH:mm:ss")} |
#if>
#if>
<#if (consumerProgressVO.ownerList?? && consumerProgressVO.ownerList?seq_contains(userInfo.user)) || userInfo.user.type == 1>
<#if consumerProgressVO.offsetMap??>
#if>
#if>
<#if consumerProgressVO.offsetMap??>
clientId |
broker |
队列 |
broker偏移量 |
消费者偏移量 |
堆积量 |
<#list consumerProgressVO.consumeStatsList as consumeStats>
${consumeStats.clientId} |
<#list consumeStats.offsetTable as mq,offset>
${mq.brokerName} |
${mq.queueId} |
${offset.brokerOffset?string(",###")}
|
${offset.consumerOffset?string(",###")}
|
${offset.brokerOffset - offset.consumerOffset}
|
#list>
#list>
#if>
|
#list>