通过计算kafka\u log\u logendoffset和kafka\u log\u logstartoffset之间的差值，并在所有分区上求和，但避免复制因子，获得主题中当前消息数的正确查询是什么？这实际上应该除以复制因子得到正确的数字：

sum without(instance,node_ip,partition)(kafka_log_logendoffset-kafka_log_logstartoffset)

如果不忽略示例/节点的ip信息，复制因子也应该可以从相同的度量中获得。另外，这个逻辑是否适用于具有紧凑清理策略的主题？
例如，这为每个主题提供了一个复制因子：

(count by (topic) (kafka_log_logendoffset{partition="0"}))

但是这不能与上面的查询结合使用，通过组合这两个prometheus查询不能获得任何结果。