Logs

nobl9 · Aug 5, 2023 · 0802328 · 0802328
1 parent c8c742d
commit 0802328
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/partition_table.go b/partition_table.go
@@ -461,7 +461,7 @@ func (p *PartitionTable) loadMessages(ctx context.Context, cons sarama.Partition
 				continue
 			}
 
-			if msg.Topic == "anomalydetector-nodata-rules-table" {
+			if msg.Topic == "anomalydetector-nodata-rules" {
 				p.log.Debugf(
 					"load messages = topic=%s, partition=%v, key=%s, offset=%v, timestamp=%v",
 					msg.Topic,
@@ -598,7 +598,7 @@ func (p *PartitionTable) updateHwmStats() {
 }
 
 func (p *PartitionTable) storeEvent(key string, value []byte, offset int64, headers []*sarama.RecordHeader) error {
-	if p.topic == "anomalydetector-nodata-rules-table" {
+	if p.topic == "anomalydetector-nodata-rules" {
 		p.log.Debugf(
 			"store event = topic=%s, partition=%v, key=%s, offset=%v",
 			p.topic,

diff --git a/processor.go b/processor.go
@@ -823,16 +823,16 @@ func (g *Processor) ConsumeClaim(session sarama.ConsumerGroupSession, claim sara
 					headers:   msg.Headers,
 					value:     msg.Value,
 				}
-				//if msg.Topic == "anomalydetector-nodata-rules-table" {
-				//	g.log.Debugf(
-				//		"topic=%s, partition=%v, key=%s, offset=%v, timestamp=%v, value=%v",
-				//		msg.Topic,
-				//		msg.Partition,
-				//		string(msg.Key),
-				//		msg.Offset,
-				//		msg.Timestamp,
-				//	)
-				//}
+				if msg.Topic == "anomalydetector-nodata-rules" {
+					g.log.Debugf(
+						"consume claim - topic=%s, partition=%v, key=%s, offset=%v, timestamp=%v, value=%v",
+						msg.Topic,
+						msg.Partition,
+						string(msg.Key),
+						msg.Offset,
+						msg.Timestamp,
+					)
+				}
 				return m
 			}():
 			case <-stopping: