From 6de57da81a67b94b4c9071d91a5c42e82baa3c4f Mon Sep 17 00:00:00 2001
From: Neil Avery <neil.avery@gmail.com>
Date: Sat, 2 Mar 2024 12:08:49 +0000
Subject: [PATCH] push to cflt 753 (#284)

* push to 753

* push to 753

* fixed test

---------

Co-authored-by: navery-max <navery@marketaxess.com>
---
 .../main/java/io/specmesh/kafka/DockerKafkaEnvironment.java   | 4 ++--
 .../io/specmesh/kafka/schema/SchemaRegistryContainer.java     | 2 +-
 .../kafka/provision/SchemaChangeSetCalculatorsTest.java       | 4 ++--
 3 files changed, 5 insertions(+), 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
index e4253f74..4b56e947 100644
--- 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
index 7070ccdb..e44c1c81 100644
--- 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
index eeb34677..e63c9463 100644
--- 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) {