default.replication.factor=3 min.insync.replicas=2 (топики созданы с такими же настройками), смотрю на метрику kafka.server:type=ReplicaFetcherManager,name=MaxLag,clientId=Replica она постоянно растет для всех брокеров кроме одного (на нем она постоянно 0), хотя на продюсере стоит настройка ack=all и фейлов нет. Кафка 2.1.0. Вот здесь https://kafka.apache.org/documentation/#upgrade_9_breaking написано что настройку replica.lag.max.messages убрали. Что же тогда эта метрика репортит?
А зачем смотрите доку на 2.2?
Обсуждают сегодня