Делает ли приложение Kafka Streams оферты для топи c, используемого для заполнения Global KTable?

Question

Я наблюдаю, как мое приложение Kafka Streams сообщает о задержке потребителя по темам, используемым для заполнения Global KTables. Верно ли, что для таких тем смещения не выполняются?

Это имело бы смысл, поскольку topi c считывается с самого начала при каждом запуске, поэтому достаточно будет отслеживать offest у потребителя.

Однако было бы полезно знать для мониторинга, чтобы исключить такие потребительские пары topi c.

Answer 1

Верно, смещения не зафиксированы для «глобальных тем» - основная причина в том, что все экземпляры KafkaStreams читают все разделы и фиксация нескольких смещений невозможна.

Вы можете по-прежнему получают доступ к метрикам «глобального потребителя», которые также сообщают об их локальном отставании.