Hi,

I am running a Clickhouse cluster on k8s and reading from Kafka topics. I am using Clickhouse 20.4.4 .18 and the 0.9.9 version of the Clickhouse operator.  The topics are in AvroConfluent format and everything worked well until I started having an exception for on eof the topics where the complaint is :"Invalid name space"
The name of namespace is something like xxx-yyyy.prod. 

Do you have any idea what this can be about? 
Many thanks!
{
    uint8_t magic;
    uint32_t schema_id;
    readBinaryBigEndian(magic, in);
    readBinaryBigEndian(schema_id, in);
    if (magic != 0x00)
    {
        throw Exception("Invalid magic byte before AvroConfluent schema identifier."
            " Must be zero byte, found " + std::to_string(int(magic)) + " instead", ErrorCodes::INCORRECT_DATA);
    }
    return schema_id;
}
AvroConfluentRowInputFormat::AvroConfluentRowInputFormat(
    const Block & header_, ReadBuffer & in_, Params params_, const FormatSettings & format_settings_)
    : IRowInputFormat(header_, in_, params_)
    , schema_registry(getConfluentSchemaRegistry(format_settings_))
    , input_stream(std::make_unique<InputStreamReadBufferAdapter>(in))
    , decoder(avro::binaryDecoder())
    , format_settings(format_settings_)
{
    decoder->init(*input_stream);
}
bool AvroConfluentRowInputFormat::readRow(MutableColumns & columns, RowReadExtension & ext)