log kafka read message error

trim21 · trim21 · commit dab7d0fade16 · 2025-03-15T21:50:15.000+08:00
diff --git a/main.go b/main.go
@@ -31,6 +31,7 @@ func main() {
 		msg, err := k.ReadMessage(ctx)
 
 		if err != nil {
+			log.Err(err).Msg("failed to read kafka message")
 			continue
 		}
 		var m KafkaMessageValue[ChiiInterest]

Original file line number	Diff line number	Diff line change
`@@ -31,6 +31,7 @@ func main() {`
`31`	`31`	`msg, err := k.ReadMessage(ctx)`
`32`	`32`
`33`	`33`	`if err != nil {`
	`34`	`+ log.Err(err).Msg("failed to read kafka message")`
`34`	`35`	`continue`
`35`	`36`	`}`
`36`	`37`	`var m KafkaMessageValue[ChiiInterest]`