diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/topics/TopicResource.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/topics/TopicResource.java
index d9c324675fb..d07776ad08b 100644
--- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/topics/TopicResource.java
+++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/topics/TopicResource.java
@@ -232,8 +232,9 @@ public class TopicResource {
     SecurityUtil.checkAdminOrBotRole(authorizer, securityContext);
     Topic topic =
             new Topic().withId(UUID.randomUUID()).withName(create.getName()).withDescription(create.getDescription())
-                    .withService(create.getService()).withPartitions(create.getPartitions()).withSchema(create.getSchema())
-                    .withSchemaType(create.getSchemaType()).withCleanupPolicies(create.getCleanupPolicies())
+                    .withService(create.getService()).withPartitions(create.getPartitions())
+                    .withSchema(create.getSchema()).withSchemaType(create.getSchemaType())
+                    .withCleanupPolicies(create.getCleanupPolicies())
                     .withMaximumMessageSize(create.getMaximumMessageSize())
                     .withMinimumInSyncReplicas(create.getMinimumInSyncReplicas())
                     .withRetentionSize(create.getRetentionSize()).withRetentionTime(create.getRetentionTime());
@@ -278,8 +279,9 @@ public class TopicResource {
 
     Topic topic =
             new Topic().withId(UUID.randomUUID()).withName(create.getName()).withDescription(create.getDescription())
-                    .withService(create.getService()).withPartitions(create.getPartitions()).withSchema(create.getSchema())
-                    .withSchemaType(create.getSchemaType()).withCleanupPolicies(create.getCleanupPolicies())
+                    .withService(create.getService()).withPartitions(create.getPartitions())
+                    .withSchema(create.getSchema()).withSchemaType(create.getSchemaType())
+                    .withCleanupPolicies(create.getCleanupPolicies())
                     .withMaximumMessageSize(create.getMaximumMessageSize())
                     .withMinimumInSyncReplicas(create.getMinimumInSyncReplicas())
                     .withRetentionSize(create.getRetentionSize()).withRetentionTime(create.getRetentionTime());
diff --git a/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/MessagingServiceResourceTest.java b/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/MessagingServiceResourceTest.java
index 7e15ff47d07..e19ab1cd471 100644
--- a/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/MessagingServiceResourceTest.java
+++ b/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/MessagingServiceResourceTest.java
@@ -326,7 +326,8 @@ public class MessagingServiceResourceTest extends CatalogApplicationTest {
 
     // Ensure deleted service does not exist
     HttpResponseException exception = assertThrows(HttpResponseException.class, () -> getService(id, authHeaders));
-    TestUtils.assertResponse(exception, NOT_FOUND, CatalogExceptionMessage.entityNotFound(Entity.MESSAGING_SERVICE, id));
+    TestUtils.assertResponse(exception, NOT_FOUND,
+            CatalogExceptionMessage.entityNotFound(Entity.MESSAGING_SERVICE, id));
 
     // Ensure deleted service does not exist when getting by name
     exception = assertThrows(HttpResponseException.class, () -> getServiceByName(name, null, authHeaders));