RHINENG-20967: add more debugging

Author: MichaelMraka

listener/upload.go

@@ -310,6 +310,7 @@ func flushEvalEvents() {
 		utils.LogWarn("err", err.Error(), WarnPayloadTracker)
 	}
 	utils.ObserveSecondsSince(tStart, messagePartDuration.WithLabelValues("buffer-sent-payload-tracker"))
+	utils.LogDebug("evaluator_messages", len(eBuffer.EvalBuffer), "payload_tracker_messages", len(eBuffer.PtBuffer), "flushed buffers")
 	// empty buffer
 	eBuffer.EvalBuffer = eBuffer.EvalBuffer[:0]
 	eBuffer.PtBuffer = eBuffer.PtBuffer[:0]
@@ -376,6 +377,8 @@ func updateSystemPlatform(tx *gorm.DB, accountID int, host *Host,
 	templateID := hostTemplate(tx, accountID, host)
 	if templateID != nil {
 		colsToUpdate = append(colsToUpdate, "template_id")
+		utils.LogDebug("inventoryID", host.ID, "candlepin_env", host.SystemProfile.Rhsm.Environments,
+			"template", *templateID, "reporter", host.Reporter)
 	}
 
 	updatesReqJSONString := string(updatesReqJSON)

manager/kafka/kafka.go

@@ -52,5 +52,6 @@ func sendInventoryIDs(inventoryIDs mqueue.EvalDataSlice) {
 // Send given systems to re-evaluation.
 func RecalcSystems(inventoryAIDs []mqueue.EvalData) {
 	batch := inventoryIDsBatch{InventoryIDs: inventoryAIDs}
+	utils.LogDebug("systems", inventoryAIDs, "systems sent to recalc")
 	inventoryIDsChan <- batch
 }