fix test.

pingcap · Sep 22, 2022 · 208624c · 208624c
1 parent 88abae1
commit 208624c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cdc/sink/mq/producer/kafka/kafka_test.go b/cdc/sink/mq/producer/kafka/kafka_test.go
@@ -332,9 +332,9 @@ func TestAdjustConfigMinInsyncReplicas(t *testing.T) {
 	topicName := "no-topic-no-min-insync-replicas"
 	err = AdjustConfig(adminClient, config, saramaConfig, "no-topic-no-min-insync-replicas")
 	require.Nil(t, err)
+
 	err = adminClient.CreateTopic(topicName, &sarama.TopicDetail{ReplicationFactor: 1}, false)
-	require.Regexp(t, ".*kafka server: Request parameters do not satisfy the configured policy.",
-		err.Error())
+	require.ErrorIs(t, err, sarama.ErrPolicyViolation)
 
 	// Report an error if the replication-factor is less than min.insync.replicas
 	// when the topic does exist.