ну я слышал, что примеры из старых книжек не компилятся, но концептуально?

Я оставлю это на ответ хаскелистам

предложу лишь посмотреть ченджлог

> координально поменялось типа с декартовых перешли на полярные? :)

kek

> координально поменялось типа с декартовых перешли на полярные? :)

Как python

я случайно)

Этого кроля случайно не отправляют.

крóлик з пѩкными ногами

только сейчас заметил что в idea в java стали помечать имена параметров, когда передаешь константы типа 0 или false

kinda named parameters

угу, прикольное

это в последнем обновлении и появилось)

и не только для констант

ждемс теперь для скалы)

по опыту - для scala это не так часто нужно

когда есть опыт и утиная типизация не помеха)

не, ну мне кажется что когда константы передаешь в метод/конструктор, то неплохо сделать как named parameter

ну так если бы имя параметра подсвечивалось IDE - можно было бы явно не помечать в коде)

ну, это опасный аргумент

если все пользуются одной IDE - да

если читаешь код вне IDE - уже сложнее

вот да, сейчас подумал, что при code review будет всё уже не очевидно

ребят, расскажите , кто как kafka-mirror maker управляет пожалуйста

не понятно как допустим стопать мирроринг и как его канонично стартовать при падении кластера

Стопишь обычным киллом, не?

так же как и кафку - киллом))

хорошо

по другому

мне нужно сказать горшочек не вари

но только для мирроринга

и запустится ли зеркалирование после рестарта кластера?

Почему нет?

Оно может и не упасть при падении кластера

так как остановить

Пишешь скрипт-стоппер, пишешь -name и грепаешь по нему

А там килл -TERM

Или просто по имени класса

ну как стопать

мирроринг конкретный

А у тебя их несколько на хосте?

у меня их нет

вообще сейчас

но нужно внедрять мирроринг

Это обычный consumer + producer

Самый простой вариант: ps ax | grep MirrorMaker | awk '{print $1}' | xargs kill

Я про другое

Как мне следить за этим консьюмером и продьюсером и управлять им

Что значит управлять?

никак, это же просто консюмер и продюсер, ты слишком многого от него хочешь)

А следить только в логах

ну или напиши сам, опенсорс же!

Я б монитом припер

И по пиду убивал бы

да можно и так, фантазия неограничена, суть что встроенного способа нету

понял

мне нужно как-то кафка- кафка контролировать

придётся стриминг джоб делать

что ты подразумеваешь под "контролем"?

ERROR: S client not available

отслеживание оффсетов, ключение,выключение, отслежвание статуса ( работает/не работает)

тогда да, только мидлваре свой костылить)

боль

флюм флюм

Скорее даже только по оффсетам. Иногда он вроде и живой, собака, а по факту может и не писать или не читать вовсе

а вы кстати как оффсеты храните

К consumer offsets

В

не понял

Расскажите побольшепожалуйста?

отдедльный кафка топик с единичным размером по каждому ключу ?

Мы не храним, кафка сама все и менеджит

можно конечно их запихать куда угодно, только вот надо ли?

В древние времена оффсеты хранились в зк, а сейчас для этого создается отдельный топик

Самой кафкой, разумеется

каак она это менеджит

вот у тебя упала кафка

сразу все узлы одновременно?

да

хорошо , даже не так

джоба упала

с какого момента ей считывать данные

после рестарта

если ты прочитал данные и закоммитил до обработки и падения то старые данные уже не прочитаются, быстрые vs медленные консюмеры

а так это просто такой же отдельный распределенный топик

Я про другое, вот у тебя есть джоб, он читает из кафки какой-нибудь топик, потом этот джоб падает посредине своей работы, пока ты востанваливал этот джоб в кафку понабежали другие сообщения, ты подымаешь джоб. Теперь вопрос, с какого оффсета джоб должен стартануть?

если та же группа консюмеров то с того же где ты начал читать в прошлый раз, оффсеты твой консюмер же не успел закоммитить

читал оффсет=5, упал, встал, читаешь начиная с оффсета=5

а как ты определяешь , что нужно с оффсета = 5 считать?

кафка определит, что для этой группы консюмеров последний закоммиченный был 5

если ты используешь earliest конечно

пусть Саша меня поправит если я ошибаюсь