С json вроде все ок получается, а с прото не выходит. Получаю в логах бесконечную ошибку "<Warning> StorageKafka (queue): Can't get assignment. It can be caused by some issue with consumer group (not enough partitions?). Will keep trying.". Причем независомо есть данные в очереди или нет. Ну и сами данные не пишутся. Вторые сутки уже ковыряюсь с этим. Может, кто помочь\подсказать? Тестовые запросы, на которых пробую завести это дело:
В чём была проблема?
Обсуждают сегодня