2019-02-24 08:51:48 UTC - Daniel Root: @Matteo Merli trying to create a
producer with a json schema:
client.getClient()
.newProducer(Schema.JSON(MyPojo.class))
.topic("my-topic")
.create()
but this is giving me an
"org.apache.pulsar.broker.service.schema.IncompatibleSchemaException:
Incompatible schema used" error. I've tried a few variations like
JSONSchema.of(MyPojo.class) but this has the same problem. Not sure what I'm
doing wrong. The consumer also throws an error but its different
(org.apache.pulsar.client.api.PulsarClientException: Can not resolve JsonSchema
'type' id of "record", not recognized as one of standard values: [STRING,
NUMBER, INTEGER, BOOLEAN, OBJECT, ARRAY, NULL, ANY]).
Any ideas?
----
