Upgrading the Confluent Plugin to 1.20-42. (#7)

Author: WadeWaldron

CHANGELOG.md

@@ -6,4 +6,8 @@
 
 ## Version 0.2.0
 
-* Initial commit of the exercise code.
+* Initial commit of the exercise code.
+
+## Version 0.3.0
+
+* Upgrade Confluent Plugin to version 1.20-42

solutions/01-connecting-to-confluent-cloud/pom.xml

@@ -30,7 +30,7 @@ under the License.
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <flink.version>1.20.0</flink.version>
-        <confluent-plugin.version>0.129.0</confluent-plugin.version>
+        <confluent-plugin.version>1.20-42</confluent-plugin.version>
         <kafka-clients.version>3.8.0</kafka-clients.version>
         <schema-registry-client.version>7.7.0</schema-registry-client.version>
         <target.java.version>21</target.java.version>

solutions/02-querying-flink-tables/pom.xml

@@ -30,7 +30,7 @@ under the License.
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <flink.version>1.20.0</flink.version>
-        <confluent-plugin.version>0.129.0</confluent-plugin.version>
+        <confluent-plugin.version>1.20-42</confluent-plugin.version>
         <kafka-clients.version>3.8.0</kafka-clients.version>
         <schema-registry-client.version>7.7.0</schema-registry-client.version>
         <target.java.version>21</target.java.version>

solutions/03-building-a-streaming-pipeline/pom.xml

@@ -30,7 +30,7 @@ under the License.
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <flink.version>1.20.0</flink.version>
-        <confluent-plugin.version>0.129.0</confluent-plugin.version>
+        <confluent-plugin.version>1.20-42</confluent-plugin.version>
         <kafka-clients.version>3.8.0</kafka-clients.version>
         <schema-registry-client.version>7.7.0</schema-registry-client.version>
         <target.java.version>21</target.java.version>

solutions/03-building-a-streaming-pipeline/src/test/java/marketplace/OrderServiceIntegrationTest.java

@@ -167,7 +167,7 @@ public void createFreeShippingTable_shouldCreateTheTable() {
         TableResult result = orderService.createFreeShippingTable();
 
         String status = result.collect().next().getFieldAs(0);
-        assertEquals("Table '"+orderQualifiedForFreeShippingShortTableName+"' created", status);
+        assertEquals("Command completed successfully.", status);
 
         env.useCatalog("flink-table-api-java");
         env.useDatabase("marketplace");

solutions/04-windowing/pom.xml

@@ -30,7 +30,7 @@ under the License.
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <flink.version>1.20.0</flink.version>
-        <confluent-plugin.version>0.129.0</confluent-plugin.version>
+        <confluent-plugin.version>1.20-42</confluent-plugin.version>
         <kafka-clients.version>3.8.0</kafka-clients.version>
         <schema-registry-client.version>7.7.0</schema-registry-client.version>
         <target.java.version>21</target.java.version>

solutions/04-windowing/src/test/java/marketplace/OrderServiceIntegrationTest.java

@@ -170,7 +170,7 @@ public void createFreeShippingTable_shouldCreateTheTable() {
         TableResult result = orderService.createFreeShippingTable();
 
         String status = result.collect().next().getFieldAs(0);
-        assertEquals("Table '"+orderQualifiedForFreeShippingShortTableName+"' created", status);
+        assertEquals("Command completed successfully.", status);
 
         env.useCatalog("flink-table-api-java");
         env.useDatabase("marketplace");
@@ -263,7 +263,7 @@ public void createOrdersForPeriodTable_shouldCreateTheTable() {
         TableResult result = orderService.createOrdersForPeriodTable();
 
         String status = result.collect().next().getFieldAs(0);
-        assertEquals("Table '"+customerOrdersForPeriodShortTableName+"' created", status);
+        assertEquals("Command completed successfully.", status);
 
         env.useCatalog("flink-table-api-java");
         env.useDatabase("marketplace");

solutions/05-joins/pom.xml

@@ -30,7 +30,7 @@ under the License.
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <flink.version>1.20.0</flink.version>
-        <confluent-plugin.version>0.129.0</confluent-plugin.version>
+        <confluent-plugin.version>1.20-42</confluent-plugin.version>
         <kafka-clients.version>3.8.0</kafka-clients.version>
         <schema-registry-client.version>7.7.0</schema-registry-client.version>
         <target.java.version>21</target.java.version>

solutions/05-joins/src/test/java/marketplace/ClickServiceIntegrationTest.java

@@ -81,7 +81,7 @@ public void createOrderPlacedAfterClickTable_shouldCreateTheTable() {
         TableResult result = clickService.createOrderPlacedAfterClickTable();
 
         String status = result.collect().next().getFieldAs(0);
-        assertEquals("Table '"+orderPlacedAfterClickShortTableName+"' created", status);
+        assertEquals("Command completed successfully.", status);
 
         env.useCatalog("flink-table-api-java");
         env.useDatabase("marketplace");

solutions/05-joins/src/test/java/marketplace/OrderServiceIntegrationTest.java

@@ -170,7 +170,7 @@ public void createFreeShippingTable_shouldCreateTheTable() {
         TableResult result = orderService.createFreeShippingTable();
 
         String status = result.collect().next().getFieldAs(0);
-        assertEquals("Table '"+orderQualifiedForFreeShippingShortTableName+"' created", status);
+        assertEquals("Command completed successfully.", status);
 
         env.useCatalog("flink-table-api-java");
         env.useDatabase("marketplace");
@@ -263,7 +263,7 @@ public void createOrdersForPeriodTable_shouldCreateTheTable() {
         TableResult result = orderService.createOrdersForPeriodTable();
 
         String status = result.collect().next().getFieldAs(0);
-        assertEquals("Table '"+customerOrdersForPeriodShortTableName+"' created", status);
+        assertEquals("Command completed successfully.", status);
 
         env.useCatalog("flink-table-api-java");
         env.useDatabase("marketplace");