fix log.

pingcap · Sep 26, 2022 · 11d65c5 · 11d65c5
1 parent 41ef21f
commit 11d65c5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/sink/mq/manager/kafka_manager.go b/cdc/sink/mq/manager/kafka_manager.go
@@ -142,7 +142,7 @@ func (m *kafkaTopicManager) getMetadataOfTopics() ([]*sarama.TopicMetadata, erro
 	topicMetaList, err := m.admin.DescribeTopics(topicList)
 	if err != nil {
 		log.Warn(
-			"kafka: get topics meta failed",
+			"Kafka admin client describe topics failed",
 			zap.Error(err),
 			zap.Duration("duration", time.Since(start)),
 		)