我观察到我的kafka streams应用程序报告用于填充全球ktables的主题的消费者延迟。对于这样的主题不提交偏移量是正确的吗？这是有意义的，因为每个创业公司都是从一开始就阅读这个主题，所以跟踪消费者的出价就足够了。不过，了解排除此类消费者主题对的监控方法是有用的。
gzszwxb41#
正确，偏移量不是为“全局主题”提交的——主要原因是，所有kafkastreams示例都读取所有分区，并且不可能提交多个偏移量。您仍然可以访问“全球消费者”指标，这些指标也会报告其本地滞后。
1条答案
按热度按时间gzszwxb41#
正确，偏移量不是为“全局主题”提交的——主要原因是，所有kafkastreams示例都读取所有分区，并且不可能提交多个偏移量。
您仍然可以访问“全球消费者”指标，这些指标也会报告其本地滞后。