From 1854e38c4054af86bc01451fdf6f8fd40aada919 Mon Sep 17 00:00:00 2001 From: hi-rustin Date: Fri, 2 Jun 2023 15:54:21 +0800 Subject: [PATCH] Fix bug Signed-off-by: hi-rustin --- cdc/sink/mq/manager/kafka_manager.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cdc/sink/mq/manager/kafka_manager.go b/cdc/sink/mq/manager/kafka_manager.go index beb3ba60254..0b19f011461 100644 --- 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) } }