Hi all;

I am drafting a proposal to support the producer to send messages with
different schema.

## Motivation
For now, Pulsar producer can only produce messages of one type of schema
which is determined by user when it is created, or by fecthing the latest
version of schema from registry if AUTO_PRODUCE_BYTES type is specified.
Schema, however, can be updated by external system after producer started,
which would lead to inconsistency between messsage payload and schema
version metadata. Also some senarios like replicating from kafka require a
single producer for replicating messages of different schemas from one
Kafka partition to one Pulsar partition to guarantee the order and no
duplicates.

Here proposing that messages can indicate the associated schema by itself,
for more detail,
https://gist.github.com/yittg/56c6dedf7509f634ec7effc4f6f3631d#file-pip-md

Looking forward to any feedback.

Thanks,
Yi

Reply via email to