push to cflt 753 (#284)

* push to 753 * push to 753 * fixed test --------- Co-authored-by: navery-max <[email protected]>
specmesh · Mar 2, 2024 · 6de57da · 6de57da
1 parent c4f7afb
commit 6de57da
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/kafka-test/src/main/java/io/specmesh/kafka/DockerKafkaEnvironment.java b/kafka-test/src/main/java/io/specmesh/kafka/DockerKafkaEnvironment.java
@@ -228,12 +228,12 @@ public static final class Builder {
         private static final int DEFAULT_CONTAINER_STARTUP_ATTEMPTS = 3;
         private static final Duration DEFAULT_CONTAINER_STARTUP_TIMEOUT = Duration.ofSeconds(30);
 
-        private static final String DEFAULT_KAFKA_DOCKER_IMAGE = "confluentinc/cp-kafka:7.3.1";
+        private static final String DEFAULT_KAFKA_DOCKER_IMAGE = "confluentinc/cp-kafka:7.5.3";
         private static final Map<String, String> DEFAULT_KAFKA_ENV =
                 Map.of("KAFKA_AUTO_CREATE_TOPICS_ENABLE", "false");
 
         private static final String DEFAULT_SCHEMA_REG_IMAGE =
-                "confluentinc/cp-schema-registry:7.3.1";
+                "confluentinc/cp-schema-registry:7.5.3";
 
         private int startUpAttempts = DEFAULT_CONTAINER_STARTUP_ATTEMPTS;
         private Duration startUpTimeout = DEFAULT_CONTAINER_STARTUP_TIMEOUT;

diff --git a/kafka-test/src/main/java/io/specmesh/kafka/schema/SchemaRegistryContainer.java b/kafka-test/src/main/java/io/specmesh/kafka/schema/SchemaRegistryContainer.java
@@ -27,7 +27,7 @@ public final class SchemaRegistryContainer extends GenericContainer<SchemaRegist
 
     private static final int KAFKA_INSECURE_BROKER_CONNECTION = 9092;
     private static final DockerImageName DEFAULT_IMAGE_NAME =
-            DockerImageName.parse("confluentinc/cp-schema-registry:7.3.1");
+            DockerImageName.parse("confluentinc/cp-schema-registry:7.5.3");
 
     /** Port the SR will listen on. */
     public static final int SCHEMA_REGISTRY_PORT = 8081;

diff --git a/kafka/src/test/java/io/specmesh/kafka/provision/SchemaChangeSetCalculatorsTest.java b/kafka/src/test/java/io/specmesh/kafka/provision/SchemaChangeSetCalculatorsTest.java
@@ -73,10 +73,10 @@ void shouldOutputMessagesOnBorkedSchema() throws Exception {
 
         final var schemas = calculator.calculate(existing, required);
         assertThat(schemas.iterator().next().state(), is(Status.STATE.FAILED));
-        assertThat(schemas.iterator().next().messages(), is(containsString("Incompatibility")));
         assertThat(
                 schemas.iterator().next().messages(),
-                is(containsString("type:READER_FIELD_MISSING_DEFAULT_VALUE")));
+                is(containsString("READER_FIELD_MISSING_DEFAULT_VALUE")));
+        assertThat(schemas.iterator().next().messages(), is(containsString("borked")));
     }
 
     private static String readFile(final String extra) {