Fix bug

Signed-off-by: hi-rustin <rustin.liu@gmail.com>
pingcap · Jun 2, 2023 · 1854e38 · 1854e38
1 parent ff6fa2d
commit 1854e38
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cdc/sink/mq/manager/kafka_manager.go b/cdc/sink/mq/manager/kafka_manager.go
@@ -299,13 +299,13 @@ func (m *kafkaTopicManager) CreateTopicAndWaitUntilVisible(topicName string) (in
 				m.tryUpdatePartitionsAndLogging(topicName, partitionNum)
 				return partitionNum, nil
 			}
-		} else {
+		} else if detail.Err != sarama.ErrUnknownTopicOrPartition {
 			log.Error("Kafka admin client describe topic failed",
 				zap.String("namespace", m.changefeedID.Namespace),
 				zap.String("changefeed", m.changefeedID.ID),
 				zap.String("topic", topicName),
-				zap.Error(err))
-			return 0, errors.Trace(err)
+				zap.Error(detail.Err))
+			return 0, errors.Trace(detail.Err)
 		}
 	}