rename stream catalog to messaging catalog

api/src/main/java/com/datastrato/gravitino/Catalog.java

@@ -24,7 +24,7 @@ enum Type {
     FILESET,
 
     /** Catalog Type for Message Queue, like kafka://topic */
-    STREAM
+    MESSAGING
   }
 
   /**

api/src/main/java/com/datastrato/gravitino/stream/StreamCatalog.java → api/src/main/java/com/datastrato/gravitino/stream/MessagingCatalog.java

@@ -13,10 +13,10 @@
 import java.util.Map;
 
 /**
- * The StreamCatalog interface defines the public API for managing topic objects in a schema. If the
- * catalog implementation supports topic objects, it should implement this interface.
+ * The MessagingCatalog interface defines the public API for managing topic objects in a schema. If
+ * the catalog implementation supports topic objects, it should implement this interface.
  */
-public interface StreamCatalog {
+public interface MessagingCatalog {
 
   /**
    * List the topics in a schema namespace from the catalog.

api/src/main/java/com/datastrato/gravitino/stream/Topic.java

@@ -15,7 +15,7 @@
  * Message Queue system like Kafka, Pulsar, etc.
  *
  * <p>{@link Topic} defines the basic properties of a topic object. A catalog implementation with
- * {@link StreamCatalog} should implement this interface.
+ * {@link MessagingCatalog} should implement this interface.
  */
 public interface Topic extends Auditable {
 

clients/client-java/src/main/java/com/datastrato/gravitino/client/DTOConverters.java

@@ -80,7 +80,7 @@ static Catalog toCatalog(CatalogDTO catalog, RESTClient client) {
             .withRestClient(client)
             .build();
 
-      case STREAM:
+      case MESSAGING:
       default:
         throw new UnsupportedOperationException("Unsupported catalog type: " + catalog.type());
     }

clients/client-java/src/test/java/com/datastrato/gravitino/client/TestGravitinoMetalake.java

@@ -125,7 +125,7 @@ public void testLoadCatalog() throws JsonProcessingException {
         new CatalogDTO.Builder()
             .withName("mock")
             .withComment("comment")
-            .withType(Catalog.Type.STREAM)
+            .withType(Catalog.Type.MESSAGING)
             .withProvider("test")
             .withAudit(
                 new AuditDTO.Builder().withCreator("creator").withCreateTime(Instant.now()).build())
@@ -182,22 +182,22 @@ public void testCreateCatalog() throws JsonProcessingException {
         new CatalogDTO.Builder()
             .withName("mock")
             .withComment("comment")
-            .withType(Catalog.Type.STREAM)
+            .withType(Catalog.Type.MESSAGING)
             .withProvider("test")
             .withAudit(
                 new AuditDTO.Builder().withCreator("creator").withCreateTime(Instant.now()).build())
             .build();
     CatalogCreateRequest req1 =
         new CatalogCreateRequest(
-            catalogName, Catalog.Type.STREAM, provider, "comment", Collections.emptyMap());
+            catalogName, Catalog.Type.MESSAGING, provider, "comment", Collections.emptyMap());
     CatalogResponse resp1 = new CatalogResponse(mockCatalog1);
     buildMockResource(Method.POST, path, req1, resp1, HttpStatus.SC_OK);
     NameIdentifier id = NameIdentifier.of(metalakeName, catalogName);
     Map<String, String> emptyMap = Collections.emptyMap();
 
     Assertions.assertThrows(
         UnsupportedOperationException.class,
-        () -> metalake.createCatalog(id, Catalog.Type.STREAM, provider, "comment", emptyMap));
+        () -> metalake.createCatalog(id, Catalog.Type.MESSAGING, provider, "comment", emptyMap));
 
     // Test return NoSuchMetalakeException
     ErrorResponse errorResponse =