eolivelli commented on a change in pull request #12886:
URL: https://github.com/apache/pulsar/pull/12886#discussion_r753755695
##########
File path: pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java
##########
@@ -304,6 +304,54 @@ public void testMultiTopicSetSchemaProviderWithKeyValue()
throws Exception {
consumer.close();
}
+ @Test
+ public void testSendAvroAndJsonPrimitiveSchema() throws Exception {
+ final String tenant = PUBLIC_TENANT;
+ final String namespace = "test-namespace-" + randomName(16);
+ final String topicOne = "test-multi-version-schema-one";
+ final String fqtnOne = TopicName.get(
+ TopicDomain.persistent.value(),
+ tenant,
+ namespace,
+ topicOne
+ ).toString();
+
+
+ admin.namespaces().createNamespace(
+ tenant + "/" + namespace,
+ Sets.newHashSet(CLUSTER_NAME)
+ );
+
+ admin.namespaces().setSchemaCompatibilityStrategy(tenant + "/" +
namespace,
+ SchemaCompatibilityStrategy.ALWAYS_COMPATIBLE);
+
+ Producer<byte[]> producer =
pulsarClient.newProducer(Schema.AUTO_PRODUCE_BYTES())
+ .topic(fqtnOne)
+ .create();
+
+ final Consumer<GenericRecord> consumer =
pulsarClient.newConsumer(Schema.AUTO_CONSUME()).topic(fqtnOne)
+ .subscriptionName("sub")
+ .subscribe();
+
+ int producerAvroIntegerValue = 1;
+ byte[] producerAvroBytesValue = "testProducerAvroBytes".getBytes();
+ producer.newMessage(Schema.AVRO(Integer.class)).value(1).send();
+
producer.newMessage(Schema.AVRO(byte[].class)).value(producerAvroBytesValue).send();
+
+ int producerJsonIntegerValue = 2;
+ byte[] producerJsonBytesValue = "testProducerJsonBytes".getBytes();
+
producer.newMessage(Schema.JSON(Integer.class)).value(producerJsonIntegerValue).send();
+
producer.newMessage(Schema.JSON(byte[].class)).value(producerJsonBytesValue).send();
+
+ // AVRO schema with primitive class can consume
+ assertEquals(consumer.receive().getValue().getNativeObject(),
producerAvroIntegerValue);
+ assertEquals(consumer.receive().getValue().getNativeObject(),
producerAvroBytesValue);
Review comment:
This is an array so we need assertArrayEquals here
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
