This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 85bfdf4127e KAFKA-17613: Remove ZK migration code (#17293)
add dbd50ff8472 KAFKA-16469: Metadata schema checker (#15995)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 1 +
checkstyle/suppressions.xml | 4 +-
.../java/org/apache/kafka/message/FieldSpec.java | 7 +
.../org/apache/kafka/message/MessageGenerator.java | 6 +-
.../org/apache/kafka/message/StructRegistry.java | 14 +-
.../java/org/apache/kafka/message/StructSpec.java | 16 +-
.../apache/kafka/message/checker/CheckerUtils.java | 94 +++++++++
.../kafka/message/checker/EvolutionException.java | 16 +-
.../kafka/message/checker/EvolutionVerifier.java | 119 +++++++++++
.../apache/kafka/message/checker/FieldDomain.java | 105 ++++++++++
.../kafka/message/checker/FieldSpecPair.java | 37 ++--
.../message/checker/FieldSpecPairIterator.java | 111 ++++++++++
.../message/checker/MetadataSchemaCheckerTool.java | 88 ++++++++
.../message/checker/UnificationException.java | 13 +-
.../org/apache/kafka/message/checker/Unifier.java | 205 +++++++++++++++++++
.../org/apache/kafka/message/StructSpecTest.java | 69 +++++++
.../kafka/message/checker/CheckerTestUtils.java | 154 ++++++++++++++
.../kafka/message/checker/CheckerUtilsTest.java | 90 +++++++++
.../message/checker/EvolutionVerifierTest.java | 202 +++++++++++++++++++
.../kafka/message/checker/FieldDomainTest.java | 59 ++++++
.../checker/MetadataSchemaCheckerToolTest.java | 54 +++++
.../apache/kafka/message/checker/UnifierTest.java | 224 +++++++++++++++++++++
22 files changed, 1641 insertions(+), 47 deletions(-)
create mode 100644
generator/src/main/java/org/apache/kafka/message/checker/CheckerUtils.java
copy
clients/src/main/java/org/apache/kafka/common/errors/InvalidRegistrationException.java
=>
generator/src/main/java/org/apache/kafka/message/checker/EvolutionException.java
(70%)
create mode 100644
generator/src/main/java/org/apache/kafka/message/checker/EvolutionVerifier.java
create mode 100644
generator/src/main/java/org/apache/kafka/message/checker/FieldDomain.java
copy trogdor/src/main/java/org/apache/kafka/trogdor/rest/Empty.java =>
generator/src/main/java/org/apache/kafka/message/checker/FieldSpecPair.java
(61%)
create mode 100644
generator/src/main/java/org/apache/kafka/message/checker/FieldSpecPairIterator.java
create mode 100644
generator/src/main/java/org/apache/kafka/message/checker/MetadataSchemaCheckerTool.java
copy
clients/src/main/java/org/apache/kafka/common/errors/TopicExistsException.java
=>
generator/src/main/java/org/apache/kafka/message/checker/UnificationException.java
(78%)
create mode 100644
generator/src/main/java/org/apache/kafka/message/checker/Unifier.java
create mode 100644
generator/src/test/java/org/apache/kafka/message/StructSpecTest.java
create mode 100644
generator/src/test/java/org/apache/kafka/message/checker/CheckerTestUtils.java
create mode 100644
generator/src/test/java/org/apache/kafka/message/checker/CheckerUtilsTest.java
create mode 100644
generator/src/test/java/org/apache/kafka/message/checker/EvolutionVerifierTest.java
create mode 100644
generator/src/test/java/org/apache/kafka/message/checker/FieldDomainTest.java
create mode 100644
generator/src/test/java/org/apache/kafka/message/checker/MetadataSchemaCheckerToolTest.java
create mode 100644
generator/src/test/java/org/apache/kafka/message/checker/UnifierTest.java