Merge branch 'release/0.9.122'

CHANGELOG.md

@@ -2,7 +2,27 @@
 
 ## [Unreleased](https://github.com/aklivity/zilla/tree/HEAD)
 
-[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.120...HEAD)
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.121...HEAD)
+
+**Fixed bugs:**
+
+- Logging wrong accept url when http proxy is configured [\#1380](https://github.com/aklivity/zilla/issues/1380)
+- Connection to MQTT server over WebSocket fails from web browser [\#1374](https://github.com/aklivity/zilla/issues/1374)
+- Zilla unable to produce to Kafka when removing the north/south cache blocks [\#1353](https://github.com/aklivity/zilla/issues/1353)
+
+**Closed issues:**
+
+- Unify ZFUNCTION and ZSTREAM into a single concept [\#1376](https://github.com/aklivity/zilla/issues/1376)
+
+**Merged pull requests:**
+
+- Support configurable TLS client SNI validation and handle FQDNs … [\#1383](https://github.com/aklivity/zilla/pull/1383) ([jfallows](https://github.com/jfallows))
+- Log accepted before overriding the headers [\#1381](https://github.com/aklivity/zilla/pull/1381) ([akrambek](https://github.com/akrambek))
+- Unify ZFUNCTION and ZSTREAM into a single concept [\#1377](https://github.com/aklivity/zilla/pull/1377) ([akrambek](https://github.com/akrambek))
+
+## [0.9.121](https://github.com/aklivity/zilla/tree/0.9.121) (2025-01-20)
+
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.120...0.9.121)
 
 **Merged pull requests:**
 

build/flyweight-maven-plugin/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>build</artifactId>
-    <version>0.9.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

cloud/helm-chart/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql.spec/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.121</version>
+    <version>0.9.122</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.121</version>
+    <version>0.9.122</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

incubator/binding-pgsql/src/main/antlr4/io/aklivity/zilla/runtime/binding/pgsql/parser/PostgreSqlLexer.g4

@@ -301,8 +301,6 @@ TOPIC: 'TOPIC';
 
 TOPICS: 'TOPICS';
 
-ZSTREAM: 'ZSTREAM';
-
 ZVIEW: 'ZVIEW';
 
 ZVIEWS: 'ZVIEWS';
@@ -558,9 +556,9 @@ FUNCTIONS: 'FUNCTIONS';
 
 ZFUNCTION: 'ZFUNCTION';
 
-ZFUNCTIONS: 'ZFUNCTIONS';
+EVENTS: 'EVENTS';
 
-ZSTREAMS: 'ZSTREAMS';
+ZFUNCTIONS: 'ZFUNCTIONS';
 
 GLOBAL: 'GLOBAL';
 

incubator/binding-pgsql/src/main/antlr4/io/aklivity/zilla/runtime/binding/pgsql/parser/PostgreSqlParser.g4

@@ -107,7 +107,6 @@ stmt
     | createseqstmt
     | createstmt
     | createztstmt
-    | createzstreamstmt
     | createsubscriptionstmt
     | createstatsstmt
     | createtablespacestmt
@@ -415,39 +414,9 @@ altertablestmt
     | ALTER MATERIALIZED VIEW (IF_P EXISTS)? qualified_name alter_table_cmds
     | ALTER MATERIALIZED VIEW ALL IN_P TABLESPACE name (OWNED BY role_list)? SET TABLESPACE name opt_nowait
     | ALTER FOREIGN TABLE (IF_P EXISTS)? relation_expr alter_table_cmds
-    | ALTER ZSTREAM (IF_P EXISTS)? relation_expr alter_zstream_cmds
     | ALTER ZVIEW (IF_P EXISTS)? qualified_name alter_table_cmds
     ;
 
-alter_zstream_cmds
-    : alter_zstream_cmd (COMMA alter_zstream_cmd)*
-    ;
-
-alter_zstream_cmd
-    : ADD_P columnDef
-    | ADD_P IF_P NOT EXISTS columnDef
-    | ADD_P COLUMN columnDef
-    | ADD_P COLUMN IF_P NOT EXISTS columnDef
-    | ALTER opt_column colid alter_column_default
-    | ALTER opt_column colid DROP NOT NULL_P
-    | ALTER opt_column colid SET NOT NULL_P
-    | ALTER opt_column colid DROP EXPRESSION
-    | ALTER opt_column colid DROP EXPRESSION IF_P EXISTS
-    | ALTER opt_column colid SET STATISTICS signediconst
-    | ALTER opt_column iconst SET STATISTICS signediconst
-    | ALTER opt_column colid SET reloptions
-    | ALTER opt_column colid RESET reloptions
-    | ALTER opt_column colid SET STORAGE colid
-    | ALTER opt_column colid ADD_P GENERATED generated_when AS IDENTITY_P optparenthesizedseqoptlist
-    | ALTER opt_column colid alter_identity_column_option_list
-    | ALTER opt_column colid DROP IDENTITY_P
-    | ALTER opt_column colid DROP IDENTITY_P IF_P EXISTS
-    | ALTER opt_column colid opt_set_data TYPE_P typename opt_collate_clause alter_using
-    | ALTER opt_column colid alter_generic_options
-    | DROP opt_column IF_P EXISTS colid opt_drop_behavior
-    | DROP opt_column colid opt_drop_behavior
-    ;
-
 alter_table_cmds
     : alter_table_cmd (COMMA alter_table_cmd)*
     ;
@@ -694,22 +663,6 @@ copy_generic_opt_arg_list_item
     : opt_boolean_or_string
     ;
 
-createzstreamstmt
-    : CREATE ZSTREAM (IF_P NOT EXISTS)? zstream_name OPEN_PAREN zstream_columns CLOSE_PAREN opt_with_zstream
-    ;
-
-zstream_name
-    : qualified_name
-    ;
-
-zstream_columns
-    : zstream_column (COMMA zstream_column)*
-    ;
-
-zstream_column
-    : colid typename opt_generated_clause
-    ;
-
 opt_generated_clause
     : GENERATED ALWAYS AS generation_type
     | /* Empty */
@@ -720,10 +673,6 @@ generation_type
     | NOW
     ;
 
-opt_with_zstream
-    : WITH OPEN_PAREN zreloptions CLOSE_PAREN
-    ;
-
 zreloptions
     : zreloption_elem (COMMA zreloption_elem)*
     ;
@@ -1679,7 +1628,6 @@ show_object_type_name
     | ZTABLES
     | ZVIEWS
     | ZFUNCTIONS
-    | ZSTREAMS
     ;
 
 dropstmt
@@ -1703,8 +1651,8 @@ object_type_any_name
     | VIEW
     | MATERIALIZED VIEW
     | TOPIC
-    | ZSTREAM
     | ZVIEW
+    | ZFUNCTION
     | ZTABLE
     | INDEX
     | FOREIGN TABLE
@@ -2043,7 +1991,19 @@ opt_nulls_order
 
 createzfunctionstmt
     : CREATE ZFUNCTION func_name func_args_with_defaults
-      RETURNS TABLE OPEN_PAREN table_func_column_list CLOSE_PAREN LANGUAGE SQL_P AS DOLLAR_DELIMITER selectstmt SEMI DOLLAR_DELIMITER
+      RETURNS TABLE OPEN_PAREN table_func_column_list CLOSE_PAREN
+      LANGUAGE SQL_P AS DOLLAR_DELIMITER selectstmt SEMI DOLLAR_DELIMITER
+      zfunc_opt_with_clause
+    ;
+
+zfunc_opt_with_clause
+    : WITH OPEN_PAREN zfunc_with_option CLOSE_PAREN
+    | /* empty */
+    ;
+
+zfunc_with_option
+    : EVENTS EQUAL sconst
+    | collabel EQUAL sconst
     ;
 
 createfunctionstmt

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

@@ -29,12 +29,10 @@
 import org.antlr.v4.runtime.dfa.DFA;
 import org.antlr.v4.runtime.tree.ParseTreeWalker;
 
-import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlAlterZstreamTopicListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlAlterZtableTopicListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlCommandListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlCreateFunctionListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlCreateZfunctionListener;
-import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlCreateZstreamListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlCreateZtableTopicListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlCreateZviewListener;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.listener.SqlDropListener;
@@ -43,7 +41,6 @@
 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.CreateZstream;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.CreateZview;
 import io.aklivity.zilla.runtime.binding.pgsql.parser.model.Drop;
 
@@ -54,10 +51,8 @@ public final class PgsqlParser
     private final CommonTokenStream tokens;
     private final PostgreSqlParser parser;
     private final SqlCommandListener commandListener;
-    private final SqlCreateZstreamListener createStreamListener;
     private final SqlCreateZtableTopicListener createTableListener;
     private final SqlAlterZtableTopicListener alterTableListener;
-    private final SqlAlterZstreamTopicListener alterStreamListener;
     private final SqlCreateFunctionListener createFunctionListener;
     private final SqlCreateZfunctionListener createZfunctionListener;
     private final SqlCreateZviewListener createMaterializedViewListener;
@@ -79,8 +74,6 @@ public PgsqlParser()
         this.commandListener = new SqlCommandListener(tokens);
         this.createTableListener = new SqlCreateZtableTopicListener(tokens);
         this.alterTableListener = new SqlAlterZtableTopicListener(tokens);
-        this.alterStreamListener = new SqlAlterZstreamTopicListener(tokens);
-        this.createStreamListener = new SqlCreateZstreamListener(tokens);
         this.createFunctionListener = new SqlCreateFunctionListener(tokens);
         this.createZfunctionListener = new SqlCreateZfunctionListener(tokens);
         this.createMaterializedViewListener = new SqlCreateZviewListener(tokens);
@@ -109,20 +102,6 @@ public Alter parseAlterTable(
         return alterTableListener.alter();
     }
 
-    public Alter parseAlterStream(
-        String sql)
-    {
-        parser(sql, alterStreamListener);
-        return alterStreamListener.alter();
-    }
-
-    public CreateZstream parseCreateZstream(
-        String sql)
-    {
-        parser(sql, createStreamListener);
-        return createStreamListener.stream();
-    }
-
     public CreateFunction parseCreateFunction(
         String sql)
     {