Merge branch 'release/0.9.126'

.github/workflows/links-check.yml

@@ -13,7 +13,7 @@ jobs:
       - uses: actions/checkout@v4
 
       - name: Link Checker
-        uses: lycheeverse/lychee-action@v2.2.0
+        uses: lycheeverse/lychee-action@v2.3.0
         with:
           fail: true
           args: --exclude-mail --exclude .+localhost.+ README.md

CHANGELOG.md

@@ -2,7 +2,34 @@
 
 ## [Unreleased](https://github.com/aklivity/zilla/tree/HEAD)
 
-[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.124...HEAD)
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.125...HEAD)
+
+**Implemented enhancements:**
+
+- Type boolean possible in schema [\#1408](https://github.com/aklivity/zilla/issues/1408)
+
+**Fixed bugs:**
+
+- Java Agent Error while sending Data to Open Telemetry Endpoint \(OTEL Endpoint\) [\#1406](https://github.com/aklivity/zilla/issues/1406)
+- Handle double quote when defining the table name in risingwave [\#1379](https://github.com/aklivity/zilla/issues/1379)
+
+**Merged pull requests:**
+
+- Handle double quote in z prefix resources [\#1412](https://github.com/aklivity/zilla/pull/1412) ([akrambek](https://github.com/akrambek))
+- Handle TLS Alert.USER\_CANCELED then deferred Alert.CLOSE\_NOTIFY [\#1411](https://github.com/aklivity/zilla/pull/1411) ([jfallows](https://github.com/jfallows))
+- support boolean model [\#1409](https://github.com/aklivity/zilla/pull/1409) ([ankitk-me](https://github.com/ankitk-me))
+- fix: resolveKind flow for composite binding [\#1407](https://github.com/aklivity/zilla/pull/1407) ([ankitk-me](https://github.com/ankitk-me))
+- fix: MQTT subscribe routing [\#1403](https://github.com/aklivity/zilla/pull/1403) ([ankitk-me](https://github.com/ankitk-me))
+- fix: mqtt-kafka routing fix [\#1402](https://github.com/aklivity/zilla/pull/1402) ([ankitk-me](https://github.com/ankitk-me))
+- fix: NPE due to empty Inline Catalog [\#1399](https://github.com/aklivity/zilla/pull/1399) ([ankitk-me](https://github.com/ankitk-me))
+- Append missing system schema to avoid exposing view in show command [\#1398](https://github.com/aklivity/zilla/pull/1398) ([akrambek](https://github.com/akrambek))
+- Bump lycheeverse/lychee-action from 2.2.0 to 2.3.0 [\#1397](https://github.com/aklivity/zilla/pull/1397) ([dependabot[bot]](https://github.com/apps/dependabot))
+- Bump ubuntu from jammy-20240808 to jammy-20250126 in /cloud/docker-image/src/main/docker [\#1393](https://github.com/aklivity/zilla/pull/1393) ([dependabot[bot]](https://github.com/apps/dependabot))
+- Bump alpine from 3.21.0 to 3.21.2 in /cloud/docker-image/src/main/docker [\#1367](https://github.com/aklivity/zilla/pull/1367) ([dependabot[bot]](https://github.com/apps/dependabot))
+
+## [0.9.125](https://github.com/aklivity/zilla/tree/0.9.125) (2025-02-05)
+
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.124...0.9.125)
 
 **Implemented enhancements:**
 

build/flyweight-maven-plugin/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>build</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

build/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

cloud/docker-image/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

cloud/docker-image/src/main/docker/Dockerfile

@@ -25,7 +25,7 @@ RUN cat zpm.json.template | sed "s/\${VERSION}/${project.version}/g" | tee zpm.j
 RUN ./zpmw install --debug --instrument --exclude-remote-repositories
 RUN ./zpmw clean --keep-image
 
-FROM ubuntu:jammy-20240808
+FROM ubuntu:jammy-20250126
 
 ENV ZILLA_VERSION ${project.version}
 

cloud/docker-image/src/main/docker/alpine.Dockerfile

@@ -27,7 +27,7 @@ RUN apk add --no-cache wget
 RUN ./zpmw install --debug --exclude-remote-repositories
 RUN ./zpmw clean --keep-image
 
-FROM alpine:3.21.0
+FROM alpine:3.21.2
 
 ENV ZILLA_VERSION ${project.version}
 

cloud/helm-chart/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

cloud/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

conf/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-amqp.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-amqp/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql-kafka.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql-kafka/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql-kafka/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/kafka/internal/schema/PgsqlKafkaKeyAvroSchemaTemplate.java

@@ -17,7 +17,7 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
-import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateTable;
+import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZtable;
 
 public class PgsqlKafkaKeyAvroSchemaTemplate extends PgsqlKafkaAvroSchemaTemplate
 {
@@ -31,7 +31,7 @@ public PgsqlKafkaKeyAvroSchemaTemplate(
 
     public String generate(
         String database,
-        CreateTable command)
+        CreateZtable command)
     {
         final String newNamespace = namespace.replace(DATABASE_PLACEHOLDER, database);
 

incubator/binding-pgsql-kafka/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/kafka/internal/schema/PgsqlKafkaValueAvroSchemaTemplate.java

@@ -26,7 +26,7 @@
 import jakarta.json.JsonValue;
 
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.Alter;
-import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateTable;
+import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZtable;
 
 public class PgsqlKafkaValueAvroSchemaTemplate extends PgsqlKafkaAvroSchemaTemplate
 {
@@ -39,7 +39,7 @@ public PgsqlKafkaValueAvroSchemaTemplate(
     }
 
     public String generate(
-        CreateTable command)
+        CreateZtable command)
     {
         final String newNamespace = namespace.replace(DATABASE_PLACEHOLDER, command.schema());
 

incubator/binding-pgsql-kafka/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/kafka/internal/stream/PgsqlKafkaProxyFactory.java

@@ -55,7 +55,7 @@
 import io.aklivity.zilla.runtime.binding.pgsql.kafka.internal.types.stream.WindowFW;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.PgsqlParser;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.Alter;
-import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateTable;
+import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZtable;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.Drop;
 import io.aklivity.zilla.runtime.engine.EngineContext;
 import io.aklivity.zilla.runtime.engine.binding.BindingHandler;
@@ -1336,7 +1336,7 @@ private void decodeCreateTopicCommand(
         }
         else if (server.commandsProcessed == 0)
         {
-            final CreateTable createTopic = parser.parseCreateTable(statement);
+            final CreateZtable createTopic = parser.parseCreateTable(statement);
             final String schema = createTopic.schema();
             final String topic = createTopic.name();
 

incubator/binding-pgsql.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.125</version>
+    <version>0.9.126</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/PgsqlParser.java

@@ -39,8 +39,8 @@
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlShowListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.Alter;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateFunction;
-import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateTable;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZfunction;
+import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZtable;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZview;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.Drop;
 
@@ -88,7 +88,7 @@ public String parseCommand(
         return commandListener.command();
     }
 
-    public CreateTable parseCreateTable(
+    public CreateZtable parseCreateTable(
         String sql)
     {
         parser(sql, createTableListener);

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/listener/SqlAlterZtableTopicListener.java

@@ -61,7 +61,7 @@ public void enterRoot(
     public void enterQualified_name(
         PostgreSqlParser.Qualified_nameContext ctx)
     {
-        String text = ctx.getText();
+        String text = ctx.getText().replace("\"", "");
         String[] split = text.split(SCHEMA_PATTERN);
         schema = split.length > 1 ? split[0] : PUBLIC_SCHEMA_NAME;
         name = split.length > 1 ? split[1] : text;

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/listener/SqlCreateZfunctionListener.java

@@ -99,7 +99,7 @@ public void enterRoot(
     public void enterCreatezfunctionstmt(
         PostgreSqlParser.CreatezfunctionstmtContext ctx)
     {
-        String text = ctx.func_name().getText();
+        String text = ctx.func_name().getText().replace("\"", "");
         String[] split = text.split(SCHEMA_PATTERN);
         schema = split.length > 1 ? split[0] : PUBLIC_SCHEMA_NAME;
         name = split.length > 1 ? split[1] : text;

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/listener/SqlCreateZtableTopicListener.java

@@ -23,15 +23,15 @@
 
 import io.aklivity.zilla.runtime.binding.pgsql.parser.PostgreSqlParser;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.PostgreSqlParserBaseListener;
-import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateTable;
-import io.aklivity.zilla.runtime.binding.pgsql.parser.model.TableColumn;
+import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZtable;
+import io.aklivity.zilla.runtime.binding.pgsql.parser.model.ZtableColumn;
 
 public class SqlCreateZtableTopicListener extends PostgreSqlParserBaseListener
 {
     private static final String PUBLIC_SCHEMA_NAME = "public";
     private static final String SCHEMA_PATTERN = "\\.";
 
-    private final List<TableColumn> columns;
+    private final List<ZtableColumn> columns;
     private final Set<String> primaryKeys;
     private final TokenStream tokens;
 
@@ -46,9 +46,9 @@ public SqlCreateZtableTopicListener(
         this.tokens = tokens;
     }
 
-    public CreateTable table()
+    public CreateZtable table()
     {
-        return new CreateTable(schema, name, columns, primaryKeys);
+        return new CreateZtable(schema, name, columns, primaryKeys);
     }
 
     @Override
@@ -65,7 +65,7 @@ public void enterRoot(
     public void enterQualified_name(
         PostgreSqlParser.Qualified_nameContext ctx)
     {
-        String text = ctx.getText();
+        String text = ctx.getText().replace("\"", "");
         String[] split = text.split(SCHEMA_PATTERN);
         schema = split.length > 1 ? split[0] : PUBLIC_SCHEMA_NAME;
         name = split.length > 1 ? split[1] : text;
@@ -112,7 +112,7 @@ private void addColumn(
                 constraints.add(tokens.getText(constraint.colconstraintelem()).toUpperCase());
             }
         }
-        columns.add(new TableColumn(columnName, dataType, constraints));
+        columns.add(new ZtableColumn(columnName, dataType, constraints));
     }
 
     private void addPrimaryKey(

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/listener/SqlCreateZviewListener.java

@@ -55,7 +55,7 @@ public void enterRoot(
     public void enterCreatezviewstmt(
         PostgreSqlParser.CreatezviewstmtContext ctx)
     {
-        String text = ctx.create_mv_target().qualified_name().getText();
+        String text = ctx.create_mv_target().qualified_name().getText().replace("\"", "");
         String[] split = text.split(SCHEMA_PATTERN);
         schema = split.length > 1 ? split[0] : PUBLIC_SCHEMA_NAME;
         name = split.length > 1 ? split[1] : text;

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/listener/SqlDropListener.java

@@ -50,7 +50,7 @@ public void enterDropstmt(
     {
         ctx.any_name_list().any_name().forEach(n ->
         {
-            String text = n.getText();
+            String text = n.getText().replace("\"", "");
             String[] split = text.split(SCHEMA_PATTERN);
             String schema = split.length > 1 ? split[0] : PUBLIC_SCHEMA_NAME;
             String name = split.length > 1 ? split[1] : text;

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/model/CreateTable.java → incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/model/CreateZtable.java

@@ -17,10 +17,10 @@
 import java.util.List;
 import java.util.Set;
 
-public record CreateTable(
+public record CreateZtable(
     String schema,
     String name,
-    List<TableColumn> columns,
+    List<ZtableColumn> columns,
     Set<String> primaryKeys)
 {
 }

incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/model/TableColumn.java → incubator/binding-pgsql/src/main/java/io/aklivity/zilla/runtime/binding/pgsql/parser/model/ZtableColumn.java

@@ -16,7 +16,7 @@
 
 import java.util.List;
 
-public record TableColumn(
+public record ZtableColumn(
     String name,
     String type,
     List<String> constraints)