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 через который обращаются клиенты с идентифика...

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

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

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

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

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

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

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

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

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

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

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