Nikita Salnikov-Tarnovski

Может кто-нибудь подсказать: есть у меня джава метод, который возвращает Future. Я хочу его кучу раз вызвать и подождать завершения всех их. А если вылетит исключение в какой-...

Правильно ли я понимаю следующую ситуацию? Есть консьюмер, который подписан на паттерн топиков, и у которого auto.offset.reset=latest. Продьюсер начинает писать данные в новый...

Очевидное решение - выставить этому топику короткий retention?

Коллеги, а почему вы с этим знанием на конференциях не выступаете? 🙂

Я не могу быстро записать 150Г данных в 1 ноду кафки?

На всякий случай подкину еще один аспект: Друид написан на Джаве, КХ, если я не ошибаюсь, на С. При необходимости разбираться с багами/писать плугины вам что будет легче - Джа...

А в кафка-клиенте (consumer/producer) можно как-то отключить регистрация JMX MBean?

А, то есть только на девушек? Вообще молодцы *сарказм*

ок, переформулирую: я собираю дерево доменных объектов в памяти. Как изменения этого дерева объектов трансформируется в changelog?

Ты все говоришь о том, что конкретные проблемы буду разные. Это конечно верно. Но процесс их выявления-то должен остаться тот же?

вы, наверное, не зря в JMX кучу метрик публикуете? На их основе же можно какие-то выводы и гипотезы делать, не?

Не понял? Вы хотите разрешить брокеру, который не в синке, становится лидером?

мне померять пропускную способность локальной сетки между 2 контейнерами на одной машине? Ок, сделаю

А где-то определена область применимости Кафки? может вы и правы, но хочется доказательной базы 🙂

telnet мой_хост_тот_что_прописал_в_конфиге_он_же_хост_машины_где_все_запущено 9092 подключается?

так, уже лучше... но это только для CompletableFeature? 🙁 просто для Future такого нет, как я вижу

Не надежнее ли оперативно работать с одним и делать mirror в другой?

“Hey guys, you ever see that really old movie, Empire Strikes Back?”

Например: как именно понять, что «уперлось в диск» или «сеть забита»?

Мне аж хочется спросить, а какие штатные утилиты удобные?