Skip to content

Conversation

@zhangshenghang
Copy link
Member

Purpose of this pull request

Does this PR introduce any user-facing change?

How was this patch tested?

Check list

@zhangshenghang zhangshenghang changed the title [Feat][Kafka] Add support for Schema Registry wire format in Protobuf deserialization [Feat][Connector-v2][Kafka] Add support for Schema Registry wire format in Protobuf deserialization Dec 11, 2025
@zhangshenghang zhangshenghang marked this pull request as ready for review December 12, 2025 14:42
Copy link
Contributor

@chl-wxp chl-wxp left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@AutoService(Factory.class)
public class KafkaSourceFactory implements TableSourceFactory {

    @Override
    public String factoryIdentifier() {
        return "Kafka";
    }

    @Override
    public OptionRule optionRule() {
        return OptionRule.builder()
                .required(KafkaSourceOptions.BOOTSTRAP_SERVERS)
                .exclusive(
                        KafkaSourceOptions.TOPIC,
                        KafkaSourceOptions.TABLE_CONFIGS,
                        KafkaSourceOptions.TABLE_LIST)
                .optional(
                        KafkaSourceOptions.START_MODE,
+             .optional(KafkaSourceOptions.STRIP_SCHEMA_REGISTRY_HEADER)

@chl-wxp
Copy link
Contributor

chl-wxp commented Dec 15, 2025

please add doc

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants