[improve][schema] Improve Incompatible Schema Exception error message…

… in ServerCnx.java (apache#23344)
lhotari · Sep 25, 2024 · cefa72c · cefa72c
1 parent 5ea4252
commit cefa72c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -3052,7 +3052,8 @@ private CompletableFuture<SchemaVersion> tryAddSchema(Topic topic, SchemaData sc
                 CompletableFuture<SchemaVersion> result = new CompletableFuture<>();
                 if (hasSchema && (schemaValidationEnforced || topic.getSchemaValidationEnforced())) {
                     result.completeExceptionally(new IncompatibleSchemaException(
-                            "Producers cannot connect or send message without a schema to topics with a schema"));
+                            "Producers cannot connect or send message without a schema to topics with a schema"
+                         + "when SchemaValidationEnforced is enabled"));
                 } else {
                     result.complete(SchemaVersion.Empty);
                 }
@@ -3727,4 +3728,4 @@ public void incrementThrottleCount() {
     public void decrementThrottleCount() {
         throttleTracker.decrementThrottleCount();
     }
-}
+}