agathis

У меня тут такая задача: читать сообщения из кафки и на основании каждого сообщения делать цепочку вызовов некоего рест-сервиса. Кровавый энтерпрайз) Желаемый паралеллизм -- о...

У нас тут любопытная история: подписчик запускает джоб чтения топика каждые три секунды дженкинсом (отдельный вопрос о корректности такого решения, но им нравится). Однако в в...

всем привет. у меня задача превратить List(Map(String -> String)) в Map(String -> List(String)), и в голову не пришло ничего лучше такого решения: https://scastie.scala-lang.o...

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

А чем снять? Вообще в том же выводе kafka-consumer-group я вижу по несколько сессий иногда.