но столкнулся с такой ошибкой:
2020.11.10 15:41:09.500287 [ 38 ] {} <Error> void DB::StorageKafka::streamThread(): Code: 27, e.displayText() = DB::Exception: Cannot parse input: expected " before: .090Z",
Я как понимаю это потому что у меня тип поля указан DateTime, а ожидается что-то другое для данных (наверное DateTime64). Я хотел бы просто узнать как обычно поступают в таких ситуациях, я как понимаю у меня есть вариант прочитать из кафки все поля timestamp в виде DateTime64 (в _queue таблице), а уже в консюмере как то преобразовывать в простой DateTime для основной таблицы?
надо включить в профиле default <date_time_input_format>best_effort</date_time_input_format> или в Kafka таблице описать тип как String а в MV переделать в DateTime используя что-нибудь типа parseDateTimeBestEffort
Обсуждают сегодня