Alexander

Подскажите а при обновлении zookeeper с 3.4 параметер snapshot.trust.empty=true и файл snapshot.0 нужны для временного хранения снэпшота ? Потом когда обновил кластер, убираеш...

А ктонибудь делал даунгрейд ? Передаю данные, делаю даунгрейд с kafka 3.0.0 zookeeper 3.6.3 до kafka 2.1.0 zookeeper 3.4.14 обновляю две ноды потом пытаюсь откатить первая но...

Подскажите для consumer'a при вызове poll сообщений таймаут будет request.timeout ? А для producer'a при отсылке сообщения это будет delivery.timeout = request.timeout + linge...

Подскажите а возможно ли использовать какойнибудь "мульти-субскрайбер" на одном соединении. В общем задача такая у меня есть http через который обращаются клиенты с идентифика...

Вопрос не совсем по kafka, по zookeeper, можно ли использовать zookeeper dlm (distributed locks) при синхронизации сетевых запросов скажем http, достаточно быстро ли он будет ...

Тестирую отказоустойчивость, кафка кластер 3 сервера 1 топик isr=2 rf=3, ложу на серверах по кругу интерфейс к сети (интерфейс один) на время меньше таймаута (2минуты), как то...

Здравствуйте есть кластер из кафки с настройками minISR=2, в него пишутся данные каждую секунду и сразу читаются, чтение происходит быстрее. Выключаем одну ноду так чтобы она ...

Подскажите есть три сервера на kafka 2.1.0 нужно мигрировать до kafka 3.0.0 без потери данных. Могу ли я поочередно обновлять кафку на каждом из серверов, перезапускать демон ...

У kafka каждый consumer это соединение к kafka server, а можно ли как то аггрегировать несколько consumer в одном соединении ? Есть ли варианты чтобы не отходить от классичес...

Здравствуйте, подскажите правильно ли я понимаю что режим идемпотентности продюсера справедлив только для одного продюсера. Т.е у меня несколько паралельных продюсеров на разн...

Подскажите а при manual commit можно ли сделать как нибудь чтобы не коммитились offset'ы которые меньше последнего закомитченного ?

Скажите а какое максимальное количество топиков для kafka адекватно ? Понятно что всё зависит от железа, набора и размера и скорости данных. Но всё же.

Может Евгений имеет ввиду linger.ms ?

@sgolod А если упавшая нода и была лидером ? Возможна же ситуация когда при восстановлении связи, при minISR=2 она не даст записать, но даст прочитать старые не консистентные ...

Здравствуйте, подскажите каким способом можно обновлять версию кафки чтобы при этом сохранить данные в топиках ? Т.е если в какой то версии будет другой бинарный формат и я об...