вычитываем альпаккой и фс2-кафкой, с альпаккой проблем меньше
Если что-то простое, фс2 Кафка хорошо чувствует себя
fs2-kafka норм в целом, но не на 100%. Используем сейчас в проекте свой форк, из которого планирую всё в апстрим перелить. Но мейнтейнер там вялый, хз сколько это продлится
а во что воткнулись в основном?
Ну ты можешь прям сейчас зайти в репу и увидеть пачку моих пулл реквестов. Плюс ещё сделали там graceful shutdown, его тоже законтрибьючу
graceful shutdown бы поглядеть
В моём форке на консьюмере есть метод stopConsuming. Можешь глянуть
https://github.com/LMnet/fs2-kafka/blob/2gis-1/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala#L417
Обсуждают сегодня