search

streamnative / pulsar-client-go

Apache Pulsar Go Client Library
https://pulsar.apache.org/
Apache License 2.0
1 stars 2 forks source link

ISSUE-739: `NewProtoSchema` is initialized as AvroSchema #265

Open sijie opened 2 years ago

sijie commented 2 years ago

Original Issue: apache/pulsar-client-go#739

Expected behavior

When using NewProtoSchema a protobuf schema for the schema registry in pulsar is expected. Besides that, what is here the desired format in the registry when schema type is PROTOBUF ?

Actual behavior

When using NewProtoSchema

https://github.com/apache/pulsar-client-go/blob/128d8ea3e24035a49fc81a516b01bc57b654a64a/pulsar/schema.go#L129

its initialized as avro schema under the hood and given schema is expected to be in an avro format.

Therefore the PROTOBUF schema type is kind of pointless at the moment and the Avro schema type could be used instead?

Steps to reproduce

producer, err := client.CreateProducer(pulsar.ProducerOptions{
        Topic:  "test",
        Schema: pulsar.NewProtoSchema(schema, nil)
})

schema is expected to have an avro format.

System configuration

Pulsar version: 2.9.1