feat 编译时插桩

2026-01-24 11:38:33 +08:00
parent 6c124f9f3f
commit 44f89f9981
3 changed files with 26 additions and 2 deletions
--- a/internal/timer/consumer.go
+++ b/internal/timer/consumer.go
@@ -23,7 +23,7 @@ type TopicQuestionAnswer struct {

 func startConsumer() {
 	kafka.NewConsumer().Consume("qgdzs.question.answer", func(ctx context.Context, msg *sarama.ConsumerMessage) error {
-		log.Infof("qgdzs.question.answer: %s", string(msg.Value))
+		log.Infof("Kafka topic: qgdzs.question.answer: %s", string(msg.Value))
 		data := &TopicQuestionAnswer{}
 		if err := json.Unmarshal(msg.Value, &data); err != nil {
 			return utils.ErrorsWrap(err)