Kafka Streams 应用程序是否为用于填充全局 KTable 的主题提交偏移量？
Does a Kafka Streams app commit offets for a topic used to fill a Global KTable?
我正在观察我的 Kafka Streams 应用程序报告消费者在用于填充 Global KTables 的主题方面存在滞后。不为此类主题提交偏移量是否正确？
这是有道理的，因为每次启动时都会从头阅读该主题，因此跟踪消费者中的 offest 就足够了。
然而，了解监控以排除此类消费者主题对会很有用。
正确，未为“全局主题”提交偏移量——主要原因是所有 KafkaStreams 实例都读取所有分区并且不可能提交多个偏移量。
您仍然可以访问“全球消费者”指标，该指标还会报告他们的本地延迟。
我正在观察我的 Kafka Streams 应用程序报告消费者在用于填充 Global KTables 的主题方面存在滞后。不为此类主题提交偏移量是否正确？
这是有道理的，因为每次启动时都会从头阅读该主题，因此跟踪消费者中的 offest 就足够了。
然而，了解监控以排除此类消费者主题对会很有用。
正确，未为“全局主题”提交偏移量——主要原因是所有 KafkaStreams 实例都读取所有分区并且不可能提交多个偏移量。
您仍然可以访问“全球消费者”指标，该指标还会报告他们的本地延迟。