кафка движок в кликхаусе требует чтобы сериализованные протобафы в кафке лежали с бинарной длиной вначале.
<Error> void DB::StorageKafka::threadFunc(): Code: 444, e.displayText() = DB::Exception:
Protobuf messages are corrupted or don't match the provided schema.
Please note that Protobuf stream is length-delimited: every message is prefixed by its length in varint