feat: support external schema registry (PIP-420)#399

Open

codelipenghui wants to merge 24 commits into

masterfrom

feat/external-schema-registry

Commits on Mar 13, 2026

proto: sync PulsarApi.proto from upstream (PIP-420 support)

codelipenghui
and
claude
committed
error: add SchemaRegistry variant for external schema errors
codelipenghui
committed
feat: add schema_id_util with magic-byte framing (PIP-420)
codelipenghui
committed
feat: add PulsarSchema trait and EncodeData struct
codelipenghui
committed
feat: add DefaultPulsarSchema bridging old traits to PulsarSchema
codelipenghui
committed
feat: add KeyValueSchema composing two inner PulsarSchema instances
codelipenghui
committed
feat: re-export PulsarSchema, EncodeData, and schema sub-types

codelipenghui
and
claude
committed
refactor: Message<T> — replace _phantom with decoded field, add value()

codelipenghui
and
claude
committed
refactor: TopicConsumer uses unified DecodedMessageReceiver channel

codelipenghui
and
claude
committed
feat: add with_schema() to ConsumerBuilder
codelipenghui
committed
feat: wire PulsarSchema decode task into TopicConsumer

codelipenghui
and
claude
committed
feat: add PulsarSchema support to Producer/ProducerBuilder with schema_id propagation

codelipenghui
and
claude
committed
feat: add pulsar-schema-confluent as workspace member

codelipenghui
and
claude
committed
fix: address PR review critical issues (C1-C5)

codelipenghui
and
claude
committed
fix: address PR review important issues (I1-I5)

codelipenghui
and
claude
committed
fix: address PR review round 2 (6 findings)

codelipenghui
and
claude
committed
fix: carry schema through build_multi_topic and fix clippy warnings

codelipenghui
and
claude
committed
fix: address review round 3 (C2, I1-I3)

codelipenghui
and
claude
committed
fix: restore backward-compatible public API

codelipenghui
and
claude
committed
fix: address review round 4 (I1-I3, Message backward compat)

codelipenghui
and
claude
committed
style: run rustfmt (stable 1.94.0) to fix CI format check

codelipenghui
and
claude
committed
fix: minimize PulsarApi.proto diff to only PIP-420 fields

codelipenghui
and
claude
committed
fix: remove needless ..Default::default() after proto revert

codelipenghui
and
claude
committed

Commits on Mar 16, 2026

fix: revert unrelated changes (clippy lints, doc cosmetics)

codelipenghui
and
claude
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

feat: support external schema registry (PIP-420)#399

feat: support external schema registry (PIP-420)#399
codelipenghui wants to merge 24 commits into
masterfrom
feat/external-schema-registry

Commits on Mar 13, 2026

proto: sync PulsarApi.proto from upstream (PIP-420 support)

error: add SchemaRegistry variant for external schema errors

feat: add schema_id_util with magic-byte framing (PIP-420)

feat: add PulsarSchema trait and EncodeData struct

feat: add DefaultPulsarSchema bridging old traits to PulsarSchema

feat: add KeyValueSchema composing two inner PulsarSchema instances

feat: re-export PulsarSchema, EncodeData, and schema sub-types

refactor: Message<T> — replace _phantom with decoded field, add value()

refactor: TopicConsumer uses unified DecodedMessageReceiver channel

feat: add with_schema() to ConsumerBuilder

feat: wire PulsarSchema decode task into TopicConsumer

feat: add PulsarSchema support to Producer/ProducerBuilder with schema_id propagation

feat: add pulsar-schema-confluent as workspace member

fix: address PR review critical issues (C1-C5)

fix: address PR review important issues (I1-I5)

fix: address PR review round 2 (6 findings)

fix: carry schema through build_multi_topic and fix clippy warnings

fix: address review round 3 (C2, I1-I3)

fix: restore backward-compatible public API

fix: address review round 4 (I1-I3, Message backward compat)

style: run rustfmt (stable 1.94.0) to fix CI format check

fix: minimize PulsarApi.proto diff to only PIP-420 fields

fix: remove needless ..Default::default() after proto revert

Commits on Mar 16, 2026

fix: revert unrelated changes (clippy lints, doc cosmetics)