From 69a389f32cd7c7d73e8be922cb8ce174b5d38965 Mon Sep 17 00:00:00 2001
From: "DESKTOP-V763RJ7\\Administrator" <835606593@qq.com>
Date: Sat, 24 Jan 2026 18:12:35 +0800
Subject: [PATCH] feat kafka

---
 internal/timer/consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/timer/consumer.go b/internal/timer/consumer.go
index 8019e76..1ecbd23 100644
--- 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)