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 TypeJava FunctionPython FunctionGo Function
String
Avro
JSON
Protobuf
ProtobufNative
Key/Value
AUTO_PRODUCE
AUTO_CONSUME

For more code examples, see Java Functions and Python Functions.