Size: a a a

2021 February 04

СК

Слава Ксенз... in pro.kafka
Знатоки кафки подскажите плз. А что значит метрика RemoteTimeMs запроса FetchFollower и почему она может быть большой?
Насколько я понял RemoteTimeMs это то, сколько мы ожидаем фолловеров. Но почему мы их тут ожидаем? Это же этот брокер отдает своим фолловерам данные. Или я что-то не понимаю?
источник

SB

S B in pro.kafka
Слава Ксенз
Знатоки кафки подскажите плз. А что значит метрика RemoteTimeMs запроса FetchFollower и почему она может быть большой?
Насколько я понял RemoteTimeMs это то, сколько мы ожидаем фолловеров. Но почему мы их тут ожидаем? Это же этот брокер отдает своим фолловерам данные. Или я что-то не понимаю?
Если речь про репликацию, то ответ надо ждать, подтверждение что данные таки доехали.
источник

SB

S B in pro.kafka
Но конкретно про этот параметр не знаю.
источник

СК

Слава Ксенз... in pro.kafka
а это не в Produce запросе должно происходить?
источник

СК

Слава Ксенз... in pro.kafka
он записал и ждет репликацию
источник

СК

Слава Ксенз... in pro.kafka
чтобы подтвердить надежную запись
источник

SB

S B in pro.kafka
Не так это работает.
источник

СК

Слава Ксенз... in pro.kafka
у меня стоит acks=-1
источник

SB

S B in pro.kafka
Точнее, может и так. Зависит.
источник

SB

S B in pro.kafka
Слава Ксенз
у меня стоит acks=-1
Это блокирующий акнолежде, то есть твой код будет висеть и ждать этих подтверждений.
источник

СК

Слава Ксенз... in pro.kafka
я в курсе
источник

SB

S B in pro.kafka
Но репликация-то есть независимо
источник

СК

Слава Ксенз... in pro.kafka
я хочу надежную запись
источник

SB

S B in pro.kafka
Асинхронная ещё.
источник

SB

S B in pro.kafka
Слава Ксенз
я хочу надежную запись
Тогда тебе надо acks повышать.
источник

СК

Слава Ксенз... in pro.kafka
так -1 это самая надежная
источник

SB

S B in pro.kafka
А, у тебя минус один.
источник

SB

S B in pro.kafka
Тогда я не помню, ты либо кворум ждёшь (вероятно), либо все реплики (менее вероятно). Перепроверь в документации.
источник

SB

S B in pro.kafka
Но не понятно тогда че ты хочешь? Надёжная запись означает блокирующий вызов.
источник

СК

Слава Ксенз... in pro.kafka
я жду всех in-sync реплик
источник