Ну на кого не взвали ответственность, решать проблему всё равно консьюмеру. А ответ на вопрос особо и не дан. Пересоздавать кафка таблицу с новыми параметрами? И возникает много вопросов. Как настроен батчинг? Как узнать какое именно сообщение корявое, если у тебя в батче например 10000 записей? В целом если нужно быстро что-то прочитать в Кафке для тестов, плюс быть готовым потерять данные из-за багов продюсера, кафка движок подойдёт. Для продакшена, я всё же его не рекомедую.
Ну на кого не взвали ответственность, решать проблему всё равно консьюмеру. А ответ на вопрос особо и не дан. Пересоздавать кафка таблицу с новыми параметрами? И возникает много вопросов. Как настроен батчинг? Как узнать какое именно сообщение корявое, если у тебя в батче например 10000 записей? В целом если нужно быстро что-то прочитать в Кафке для тестов, плюс быть готовым потерять данные из-за багов продюсера, кафка движок подойдёт. Для продакшена, я всё же его не рекомедую.