diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java index 37795438dbaf3..0795a9a6cc053 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaTest.java @@ -278,7 +278,7 @@ public void testInvalidSchemaDataException(ApiVersion version) { admin.schemas().createSchema(topicName, schemaInfo); } catch (PulsarAdminException e) { Assert.assertEquals(e.getStatusCode(), 422); - Assert.assertEquals(e.getMessage(), "HTTP 422 Invalid schema definition data for AVRO schema"); + Assert.assertTrue(e.getMessage().contains("Invalid schema definition data for AVRO schema")); } } diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java index 318c404282a94..6ae18724166f6 100644 --- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java +++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java @@ -241,6 +241,9 @@ public Status.Family getFamily() { @Override public String getReasonPhrase() { + if (response.hasResponseBody()) { + return response.getResponseBody(); + } return response.getStatusText(); } });