A
Size: a a a
2019 November 22
M
В теории может быть так и стоит оставить, выставить max.poll.interval.ms на тот интервал который мы будем пробовать, а потом вся консьюмер группа будет мертва до момента пока система не оживёт и мы не сможем протолкнуть все то что в буферах валяется. Затем будет poll , ребаланс ... вроде складывается и можно будет без pause обойтись
2019 November 24
IE
Привет!
А есть tl;dr на тему, как kafka producer (моё приложение) должно находить, к какому серверу из кластера обращаться для записи данных?
Надо ли ставить haproxy\keepalived перед кафкой?
А есть tl;dr на тему, как kafka producer (моё приложение) должно находить, к какому серверу из кластера обращаться для записи данных?
Надо ли ставить haproxy\keepalived перед кафкой?
VG
Привет!
А есть tl;dr на тему, как kafka producer (моё приложение) должно находить, к какому серверу из кластера обращаться для записи данных?
Надо ли ставить haproxy\keepalived перед кафкой?
А есть tl;dr на тему, как kafka producer (моё приложение) должно находить, к какому серверу из кластера обращаться для записи данных?
Надо ли ставить haproxy\keepalived перед кафкой?
Нет
IE
Продюсеру нужен только bootstrap server, все остальные сервера прилетят с метадатой
бутстрап-сервер может меняться динамически? Мне стоит отдать кафку в консул?
IE
Продьюсер должен откуда-то найти, где ему искать этот бутстрап сервер.
Бутстрап — это один сервер, раз и навсегда?
Бутстрап — это один сервер, раз и навсегда?
IE
Если да, то что будет с продьюсерами, если он будет лежать?
VG
Если да, то что будет с продьюсерами, если он будет лежать?
Две ситуации
- продюсер стартует
- продюсер уже работает
- продюсер стартует
- продюсер уже работает
IE
1) бутстрапсервер должен быть up на момент старта продюсера
то есть это какая-то из нод, выбранная за наиболее доступную, так?
VG
то есть это какая-то из нод, выбранная за наиболее доступную, так?
Нет, первая доступная из списка (если несколько серверов в списке)
IE