[pulsar] branch master updated (8bb756f -> c01b1ee)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 8bb756f  update mongo reactivestreams version (#8190)
     add c01b1ee  [schemaregistry]ProtobufNative Schema Support (#8372)

No new revisions were added by this update.

Summary of changes:
 .../apache/pulsar/broker/ServiceConfiguration.java |   9 +-
 .../ProtobufNativeSchemaCompatibilityCheck.java    |  73 +++++++++++
 ...java => ProtobufNativeSchemaDataValidator.java} |  42 +++---
 .../schema/validator/SchemaDataValidator.java      |   3 +
 .../src/main/proto/SchemaRegistryFormat.proto      |   1 +
 ...ProtobufNativeSchemaCompatibilityCheckTest.java |  50 ++++++++
 .../java/org/apache/pulsar/client/api/Schema.java  |  21 +++
 .../client/internal/DefaultImplementation.java     |  28 +++-
 .../apache/pulsar/common/schema/SchemaInfo.java    |   1 +
 .../apache/pulsar/common/schema/SchemaType.java    |   7 +
 .../client/impl/schema/AutoConsumeSchema.java      |   9 +-
 ...otobufSchema.java => ProtobufNativeSchema.java} |  72 ++++++-----
 .../impl/schema/ProtobufNativeSchemaUtils.java     | 142 +++++++++++++++++++++
 .../generic/GenericProtobufNativeReader.java       |  83 ++++++++++++
 ...ecord.java => GenericProtobufNativeRecord.java} |  33 +++--
 .../generic/GenericProtobufNativeSchema.java       | 111 ++++++++++++++++
 .../GenericProtobufNativeWriter.java}              |  10 +-
 .../generic/ProtobufNativeRecordBuilderImpl.java   |  72 +++++++++++
 .../impl/schema/reader/ProtobufNativeReader.java   |  13 +-
 .../impl/schema/writer/ProtobufNativeWriter.java   |  11 +-
 .../impl/schema/ProtobufNativeSchemaTest.java      | 103 +++++++++++++++
 .../impl/schema/ProtobufNativeSchemaUtilsTest.java |  44 +++++++
 .../client/impl/schema/ProtobufSchemaTest.java     |  36 +++---
 .../schema/generic/AbstractGenericSchemaTest.java  |  98 ++++++++++++++
 .../generic/GenericProtobufNativeReaderTest.java   |  71 +++++++++++
 .../generic/GenericProtobufNativeSchemaTest.java   |  66 ++++++++++
 .../src/test/proto/ExternalTest.proto              |  14 +-
 pulsar-client/src/test/proto/Test.proto            |   8 ++
 .../apache/pulsar/common/api/proto/PulsarApi.java  |   3 +
 ...Response.java => ProtobufNativeSchemaData.java} |  18 ++-
 pulsar-common/src/main/proto/PulsarApi.proto       |   1 +
 31 files changed, 1124 insertions(+), 129 deletions(-)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/ProtobufNativeSchemaCompatibilityCheck.java
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/{StringSchemaDataValidator.java => ProtobufNativeSchemaDataValidator.java} (56%)
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/ProtobufNativeSchemaCompatibilityCheckTest.java
 copy pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/{ProtobufSchema.java => ProtobufNativeSchema.java} (60%)
 create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/ProtobufNativeSchemaUtils.java
 create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericProtobufNativeReader.java
 copy pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/{VersionedGenericRecord.java => GenericProtobufNativeRecord.java} (58%)
 create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericProtobufNativeSchema.java
 copy pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/{writer/ProtobufWriter.java => generic/GenericProtobufNativeWriter.java} (72%)
 create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/ProtobufNativeRecordBuilderImpl.java
 copy pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/StringSink.java => pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/ProtobufNativeReader.java (75%)
 copy pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/StringSource.java => pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/writer/ProtobufNativeWriter.java (78%)
 create mode 100644 pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/ProtobufNativeSchemaTest.java
 create mode 100644 pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/ProtobufNativeSchemaUtilsTest.java
 create mode 100644 pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/generic/AbstractGenericSchemaTest.java
 create mode 100644 pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/generic/GenericProtobufNativeReaderTest.java
 create mode 100644 pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/generic/GenericProtobufNativeSchemaTest.java
 copy pulsar-broker-common/src/main/java/org/apache/pulsar/common/configuration/PulsarConfiguration.java => pulsar-client/src/test/proto/ExternalTest.proto (77%)
 copy pulsar-common/src/main/java/org/apache/pulsar/common/protocol/schema/{IsCompatibilityResponse.java => ProtobufNativeSchemaData.java} (69%)