Use schema registry
Pulsar has a built-in schema registry and is bundled with popular schema types. Pulsar Functions can leverage the existing schema information from input topics and derive the input type. The schema registry applies to output topics as well.
The following table outlines the supportability of schema types in Pulsar Functions.
Schema Type | Java Function | Python Function | Go Function |
---|---|---|---|
String | ✅ | ✅ | |
Avro | ✅ | ✅ | |
JSON | ✅ | ✅ | |
Protobuf | ✅ | ||
ProtobufNative | ✅ | ||
Key/Value | ✅ | ||
AUTO_PRODUCE | ✅ | ||
AUTO_CONSUME | ✅ |
For more code examples, see Java Functions and Python Functions.