Morning all, I am trying to restore the indices via the restore-indices-job. I am getting logs like the following:

2022-06-30 10:56:22.625 ERROR 1 --- [           main] c.l.m.dao.producer.KafkaEventProducer    : Failed to emit MCL for entity with urn urn:li:corpuser:<username removed>
org.apache.kafka.common.errors.TimeoutException: Topic MetadataChangeLog_Versioned_v1 not present in metadata after 60000 ms.

I am not sure that it is actually doing anything and the process is running for more than 20 hours. So, I am getting failed to emit MCL for entity for all the entities. Is that normal? How can I fix that?

Hi @agreeable-belgium-70840! It looks like

MetadataChangeLog_Versioned_v1

is not an existing topic in your cluster; this should be auto-provisioned when you run the helm set up