我正在观察我的 Kafka Streams 应用程序报告用于填充全局 KTable 的主题的消费者滞后。未针对此类主题提交偏移量是否正确?
这是有道理的,因为每次启动时都会从头开始阅读该主题,因此跟踪消费者的喜好就足够了。
然而,了解监控以排除此类消费者主题对是有用的。
apache-kafka apache-kafka-streams
apache-kafka ×1
apache-kafka-streams ×1