Open david-streamlio opened 2 years ago
Currently, the NiFi processors that publish to Pulsar use the Schema.BYTES schema. They need to make their output match the topics current schema.
Need to support Schema.JSON, Schema.AVRO. How to set schemas, send to the topic
Currently, the NiFi processors that publish to Pulsar use the Schema.BYTES schema. They need to make their output match the topics current schema.