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)