From e16fc0dae6b930b0e28df3982d780b4054653edc Mon Sep 17 00:00:00 2001
From: Jyothsna Konisa <jyothsna1503@gmail.com>
Date: Tue, 5 May 2026 12:52:29 -0700
Subject: [PATCH] CASSANALYTICS-166 com.apple.mg namespace in cdc_bytes.avsc
 and cdc_generic_record.avsc

---
 .../org/apache/cassandra/cdc/kafka/TopicSupplier.java     | 6 +++---
 .../src/main/resources/cdc_bytes.avsc                     | 8 ++++----
 .../src/main/resources/cdc_generic_record.avsc            | 8 ++++----
 3 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.java b/cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.java
index 27d18346c..220f8166c 100644
--- a/cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.java
+++ b/cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.java
@@ -44,7 +44,7 @@ static StaticTopicSupplier staticTopicSupplier(String topic)
     }
 
     /**
-     * @param format topic string format like "org.apple.ase.%s"
+     * @param format topic string format like "org.apache.cassandra.%s"
      * @return a topic provider that formats a string template to include the keyspace name
      */
     static PerKeyspace keyspaceSupplier(String format)
@@ -53,7 +53,7 @@ static PerKeyspace keyspaceSupplier(String format)
     }
 
     /**
-     * @param format topic string format like "org.apple.ase.%s.%s"
+     * @param format topic string format like "org.apache.cassandra.%s.%s"
      * @return a topic provider that formats a string template to include the keyspace and table name
      */
     static PerKeyspaceTable keyspaceTableSupplier(String format)
@@ -62,7 +62,7 @@ static PerKeyspaceTable keyspaceTableSupplier(String format)
     }
 
     /**
-     * @param format topic string format like "org.apple.ase.%s"
+     * @param format topic string format like "org.apache.cassandra.%s"
      * @return a topic provider that formats a string template to include the table name
      */
     static PerTable tableSupplier(String format)
diff --git a/cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc b/cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc
index 56c9e2b15..3914f9669 100644
--- a/cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc
+++ b/cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc
@@ -53,7 +53,7 @@
       "type": {
         "type": "enum",
         "name": "OperationType",
-        "namespace": "com.apple.mg",
+        "namespace": "org.apache.cassandra",
         "symbols": [
           "INSERT",
           "UPDATE",
@@ -91,7 +91,7 @@
           "items": {
             "type": "record",
             "name": "RangePredicate",
-            "namespace": "com.apple.mg",
+            "namespace": "org.apache.cassandra",
             "fields": [
               {
                 "name": "field",
@@ -102,7 +102,7 @@
                 "type": {
                   "type": "enum",
                   "name": "RangePredicateType",
-                  "namespace": "com.apple.mg",
+                  "namespace": "org.apache.cassandra",
                   "symbols": [
                     "LT",
                     "LTE",
@@ -132,7 +132,7 @@
         {
           "type": "record",
           "name": "TTL",
-          "namespace": "com.apple.mg",
+          "namespace": "org.apache.cassandra",
           "fields": [
             {
               "name": "ttl",
diff --git a/cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc b/cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc
index cd0a9fffc..84a528cb1 100644
--- a/cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc
+++ b/cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc
@@ -53,7 +53,7 @@
       "type": {
         "type": "enum",
         "name": "OperationType",
-        "namespace": "com.apple.mg",
+        "namespace": "org.apache.cassandra",
         "symbols": [
           "INSERT",
           "UPDATE",
@@ -91,7 +91,7 @@
           "items": {
             "type": "record",
             "name": "RangePredicate",
-            "namespace": "com.apple.mg",
+            "namespace": "org.apache.cassandra",
             "fields": [
               {
                 "name": "field",
@@ -102,7 +102,7 @@
                 "type": {
                   "type": "enum",
                   "name": "RangePredicateType",
-                  "namespace": "com.apple.mg",
+                  "namespace": "org.apache.cassandra",
                   "symbols": [
                     "LT",
                     "LTE",
@@ -132,7 +132,7 @@
         {
           "type": "record",
           "name": "TTL",
-          "namespace": "com.apple.mg",
+          "namespace": "org.apache.cassandra",
           "fields": [
             {
               "name": "ttl",