You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2019/11/04 15:12:49 UTC

[pulsar] branch master updated (7f513e5 -> f6701f1)

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

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


    from 7f513e5  [Doc] Add work flow of checking broken links (#5529)
     add f6701f1  [PIP-44] Separate schema compatibility checker for producer and consumer (#5227)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/broker/admin/impl/NamespacesBase.java   |  37 +++
 .../apache/pulsar/broker/admin/v2/Namespaces.java  |  55 +++
 .../pulsar/broker/admin/v2/SchemasResource.java    |  71 ++--
 .../pulsar/broker/service/AbstractTopic.java       |  27 +-
 .../apache/pulsar/broker/service/ServerCnx.java    |  20 +-
 .../org/apache/pulsar/broker/service/Topic.java    |   4 +-
 .../service/nonpersistent/NonPersistentTopic.java  |  20 +-
 .../broker/service/persistent/PersistentTopic.java |  36 +-
 .../schema/AvroSchemaBasedCompatibilityCheck.java  |   3 +
 .../service/schema/BookkeeperSchemaStorage.java    |  91 +----
 .../schema/DefaultSchemaRegistryService.java       |  11 +-
 .../schema/JsonSchemaCompatibilityCheck.java       |   1 +
 .../schema/KeyValueSchemaCompatibilityCheck.java   |   1 +
 .../service/schema/SchemaCompatibilityCheck.java   |   3 +-
 .../broker/service/schema/SchemaRegistry.java      |   5 +
 .../service/schema/SchemaRegistryServiceImpl.java  | 132 +++++---
 .../broker/service/schema/SchemaStorage.java       |   2 +-
 ...hemaRegistryServiceWithSchemaDataValidator.java |   7 +-
 .../broker/admin/AdminApiSchemaAutoUpdateTest.java |   2 +-
 .../schema/BaseAvroSchemaCompatibilityTest.java    |   1 +
 .../schema/JsonSchemaCompatibilityCheckTest.java   |   1 +
 .../KeyValueSchemaCompatibilityCheckTest.java      |   1 +
 .../broker/service/schema/SchemaServiceTest.java   |   2 +-
 ...RegistryServiceWithSchemaDataValidatorTest.java |   2 +-
 .../api/SimpleTypedProducerConsumerTest.java       |   5 +-
 .../SchemaCompatibilityCheckTest.java              | 370 +++++++++++++++++++++
 .../pulsar/schema/compatibility/Schemas.java       |  68 ++--
 .../org/apache/pulsar/client/admin/Namespaces.java |  69 +++-
 .../client/admin/internal/NamespacesImpl.java      |  47 +++
 .../org/apache/pulsar/admin/cli/CmdNamespaces.java |  78 +++++
 .../pulsar/client/impl/HttpLookupService.java      |   5 +-
 .../pulsar/client/impl/schema/StructSchema.java    |   7 +-
 .../client/impl/schema/reader/AvroReader.java      |   2 +-
 .../pulsar/common/policies/data/Policies.java      |  19 +-
 .../data}/SchemaCompatibilityStrategy.java         |  25 +-
 .../tests/integration/schema/SchemaTest.java       |  21 +-
 .../pulsar/tests/integration/schema/Schemas.java   |  51 +++
 ...ulsar-sql-suite.xml => pulsar-schema-suite.xml} |   2 +-
 .../{pulsar-sql.xml => pulsar-schema.xml}          |   6 +-
 tests/integration/src/test/resources/pulsar.xml    |   1 +
 40 files changed, 1024 insertions(+), 287 deletions(-)
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/schema/compatibility/SchemaCompatibilityCheckTest.java
 copy pulsar-functions/api-java/src/test/java/org/apache/pulsar/functions/api/utils/JavaSerDeTest.java => pulsar-broker/src/test/java/org/apache/pulsar/schema/compatibility/Schemas.java (52%)
 rename {pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema => pulsar-common/src/main/java/org/apache/pulsar/common/policies/data}/SchemaCompatibilityStrategy.java (90%)
 copy tests/integration/src/test/resources/{pulsar-sql-suite.xml => pulsar-schema-suite.xml} (95%)
 copy tests/integration/src/test/resources/{pulsar-sql.xml => pulsar-schema.xml} (80%)