Kafka Streams 应用程序是否提交用于填充全局 KTable 的主题的偏移量？

Question

我正在观察我的 Kafka Streams 应用程序报告用于填充全局 KTable 的主题的消费者滞后。未针对此类主题提交偏移量是否正确？

这是有道理的，因为每次启动时都会从头开始阅读该主题，因此跟踪消费者的喜好就足够了。

然而，了解监控以排除此类消费者主题对是有用的。

Answer 1

正确的是，偏移量不会提交给“全局主题”——主要原因是，所有 KafkaStreams 实例都会读取所有分区，并且不可能提交多个偏移量。

您仍然可以访问“全球消费者”指标，这些指标也报告其本地滞后。