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!
auto nested_deserialize = createDeserializeFn(root_node->leafAt(non_null_union_index), removeNullable(target_type));
                return [non_null_union_index, nested_deserialize](IColumn & column, avro::Decoder & decoder)
                {
                    ColumnNullable & col = assert_cast<ColumnNullable &>(column);
                    size_t union_index = decoder.decodeUnionIndex();
                    if (union_index == non_null_union_index)
                    {
                        nested_deserialize(col.getNestedColumn(), decoder);
                        col.getNullMapData().push_back(0);
                    }
                    else
                    {
                        col.insertDefault();
                    }
                };
            };
            if (root_node->leaves() == 2 && target.isNullable())
            {
                if (root_node->leafAt(0)->type() == avro::AVRO_NULL)
                    return nullable_deserializer(1);
                if (root_node->leafAt(1)->type() == avro::AVRO_NULL)
                    return nullable_deserializer(0);
            }
            break;
        }
        case avro::AVRO_NULL:
            if (target.isNullable())
            {
                auto nested_type = removeNullable(target_type);
                if (nested_type->getTypeId() == TypeIndex::Nothing)