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%)