diff --git a/metadata-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/MetadataAuditEventsProcessor.java b/metadata-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/MetadataAuditEventsProcessor.java index 962c5e29e759dd..30c44d5fa838c7 100644 --- a/metadata-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/MetadataAuditEventsProcessor.java +++ b/metadata-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/MetadataAuditEventsProcessor.java @@ -5,6 +5,7 @@ import com.linkedin.data.template.RecordTemplate; import com.linkedin.gms.factory.common.GraphServiceFactory; import com.linkedin.gms.factory.search.SearchServiceFactory; +import com.linkedin.gms.factory.usage.UsageServiceFactory; import com.linkedin.metadata.EventUtils; import com.linkedin.metadata.PegasusUtils; import com.linkedin.metadata.dao.utils.RecordUtils; @@ -49,7 +50,7 @@ @Slf4j @Component @Conditional(MetadataAuditEventsProcessorCondition.class) -@Import({GraphServiceFactory.class, SearchServiceFactory.class}) +@Import({GraphServiceFactory.class, SearchServiceFactory.class, UsageServiceFactory.class}) @EnableKafka public class MetadataAuditEventsProcessor {