fix: change es message structure

opengovern · Nov 5, 2024 · d8f923c · d8f923c
1 parent 552b688
commit d8f923c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/describer/resource_sender.go b/pkg/describer/resource_sender.go
@@ -111,7 +111,7 @@ func (s *ResourceSender) ResourceHandler() {
 				return
 			}
 
-			s.resourceIDs = append(s.resourceIDs, resource.ID)
+			s.resourceIDs = append(s.resourceIDs, resource.ResourceID)
 			s.sendBuffer = append(s.sendBuffer, resource)
 
 			if len(s.sendBuffer) > MaxBufferSize {
@@ -169,7 +169,7 @@ func (s *ResourceSender) flushBuffer(force bool) {
 		kafkaResource.EsIndex = idx
 
 		lookupResource := es.LookupResource{
-			ProviderID:      resource.ProviderID,
+			PlatformID:      resource.PlatformID,
 			ResourceID:      resource.ResourceID,
 			ResourceName:    resource.ResourceName,
 			IntegrationType: configs.IntegrationName,