Разве там нужен балансир? Кафка сама же лидеров партиций раскидывает, продюсер уже в лидеров стреляет
Кто нибудь владеет тайным знанием jdbc, когда мы имеем несколько резалт сетов и от стейтмента берём getMoreResult. Он раз 10 возвращает false, а потом true. Как это поумнее об...
Всем привет. Возникла ошибка при транзакционнной отправке в кафку. Invalid transition attempted from state IN_TRANSACTION to state IN_TRANSACTION. Кто-нибудь знает что могло ...
Привет, возможно ли в идее быстро заимплементить интерфейс, чтобы все методы вызывали делегата? Делегат это тот же самый интерфейс который в конструктор приезжает. А то в этом...
Кто-нибудь встречался с проблемой, что при выполнении таски clean градла удаляется весь локальный репозиторий, а не папка билд?)
Всем привет, такой вопрос. У меня есть процесс чувствительный к летенси, поэтому во время редеплоя ноды кластера приложения из-за ребаланса консюмеров сообщение не успевает до...
Привет всем. zkserver.sh status выдает "Error contacting service. It is probably not running" в какую сторону копать? Гугл что-то не помог
Вопрос, допустим у меня 5 нод приложения, в каждом свой консюмер одного и того же топика, каждый в своей группе. Через год я хочу поднять шестую ноду, там появится новый кон...
Всем привет. Задача мигрировать с Кафка 2.0.0 на 2.5.0. как лучше это осуществить без даунтайма. Пока мне кажется наилучший способ использовать миррор мейкер. Но вопрос в том ...
Вопрос, создаю completablefuture.delayedExecutor(100, timeunit.milliseconds) Передаю его в completablefuture.runasync Работало хорошо, но в какой то момент, таска стала выпо...
Всем привет. Кто знает почему при вызове ./kafka-topics.sh --list --zookeeper:2181 Кафка может не показывать ни один топик? Уточню, что зукипер запущен не тот, который в кафк...
А как этот консюмер будет обеспечивать нужную задержку? Если будет в ожидание уходить то очередь колом встанет и будут постоянные ребалансы
Всем привет, в кафке есть варик размазать большую партицию по остальным? Reassign-partition умеет такое ?