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)