diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java index 5c8336116a593..3c6f7c73fbc9b 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java @@ -707,8 +707,7 @@ public void testNullKeyValueProperty() throws PulsarAdminException, PulsarClient map.put("key", null); map.put(null, "value"); // null key is not allowed for JSON, it's only for test here - // leave INT32 instance unchanged - final Schema integerSchema = Schema.INT32.clone(); + final Schema integerSchema = Schema.JSON(Integer.class); ((SchemaInfoImpl) integerSchema.getSchemaInfo()).setProperties(map); final Consumer consumer = pulsarClient.newConsumer(integerSchema).topic(topic)