From 43a71dd6d2f4540236d78e21d3bb79255c4ab43d Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Wed, 25 Oct 2023 11:53:22 -0400 Subject: [PATCH] Update expected value in kafka it tests --- apier/v1/cdre_kafka_it_test.go | 2 +- general_tests/cdrs_onlexp_it_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/apier/v1/cdre_kafka_it_test.go b/apier/v1/cdre_kafka_it_test.go index d25435daa..0eb4d7434 100644 --- a/apier/v1/cdre_kafka_it_test.go +++ b/apier/v1/cdre_kafka_it_test.go @@ -296,7 +296,7 @@ func testKafkaDeleteTopic(t *testing.T) { t.Fatal(err) } - experr := `[5] Leader Not Available: the cluster is in the middle of a leadership election and there is currently no leader for this partition and hence it is unavailable for writes` + experr := `[3] Unknown Topic Or Partition: the request is for a topic or partition that does not exist on this broker` _, err = conn.ReadPartitions("cgrates_cdrs") if err == nil || err.Error() != experr { t.Errorf("expected: <%+v>, \nreceived: <%+v>", experr, err) diff --git a/general_tests/cdrs_onlexp_it_test.go b/general_tests/cdrs_onlexp_it_test.go index a3a419382..1a057c048 100644 --- a/general_tests/cdrs_onlexp_it_test.go +++ b/general_tests/cdrs_onlexp_it_test.go @@ -614,7 +614,7 @@ func testCDRsOnExpKafkaPosterDeleteTopic(t *testing.T) { t.Fatal(err) } - experr := `[5] Leader Not Available: the cluster is in the middle of a leadership election and there is currently no leader for this partition and hence it is unavailable for writes` + experr := `[3] Unknown Topic Or Partition: the request is for a topic or partition that does not exist on this broker` _, err = conn.ReadPartitions("cgrates_cdrs") if err == nil || err.Error() != experr { t.Errorf("expected: <%+v>, \nreceived: <%+v>", experr, err)