Merge branch 'release/0.9.93'

.github/workflows/links-check.yml

@@ -0,0 +1,21 @@
+name: Link Checker
+
+on:
+  repository_dispatch:
+  workflow_dispatch:
+  schedule:
+    - cron: "0 0 * * *"
+
+jobs:
+  linkChecker:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+
+      - name: Link Checker
+        uses: lycheeverse/[email protected]
+        with:
+          fail: true
+          args: --exclude-mail --exclude .+localhost.+ README.md
+        env:
+          GITHUB_TOKEN: ${{secrets.GITHUB_TOKEN}}

.github_changelog_generator

@@ -0,0 +1,3 @@
+user=aklivity
+project=zilla
+enhancement-labels=enhancement,story

CHANGELOG.md

@@ -2,12 +2,59 @@
 
 ## [Unreleased](https://github.com/aklivity/zilla/tree/HEAD)
 
-[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.91...HEAD)
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.92...HEAD)
+
+**Implemented enhancements:**
+
+- Support `pgsql` binding [\#1057](https://github.com/aklivity/zilla/issues/1057)
+- Handle large HTTP headers [\#1046](https://github.com/aklivity/zilla/issues/1046)
+- Gracefully handle `zilla.yml` instead of `zilla.yaml` [\#580](https://github.com/aklivity/zilla/issues/580)
+
+**Fixed bugs:**
+
+- Zilla OpenAPI not supporting filesystem catalog [\#1225](https://github.com/aklivity/zilla/issues/1225)
+- Zilla produces corrupt messages due to incorrect CRC when fragmented [\#1221](https://github.com/aklivity/zilla/issues/1221)
+- Issue referencing `guard` in `asyncapi` binding [\#1215](https://github.com/aklivity/zilla/issues/1215)
+- Using catalog::apicurio triggers unexpected behaviour [\#1202](https://github.com/aklivity/zilla/issues/1202)
+- `400 Bad Request` response from Zilla when Using Java HttpClient [\#1192](https://github.com/aklivity/zilla/issues/1192)
+- Investigate connection pool reconnect when Kafka not yet available [\#1153](https://github.com/aklivity/zilla/issues/1153)
+
+**Merged pull requests:**
+
+- Refactor vault handler [\#1236](https://github.com/aklivity/zilla/pull/1236) ([jfallows](https://github.com/jfallows))
+- Mqtt flow control fix [\#1233](https://github.com/aklivity/zilla/pull/1233) ([bmaidics](https://github.com/bmaidics))
+- Fix incorrect flush acknowledgement in KafkaCacheClientProduceFactory [\#1232](https://github.com/aklivity/zilla/pull/1232) ([bmaidics](https://github.com/bmaidics))
+- http binding update to support header overrides  at route level [\#1231](https://github.com/aklivity/zilla/pull/1231) ([ankitk-me](https://github.com/ankitk-me))
+- Update asyncapi binding module-info to open parser package [\#1227](https://github.com/aklivity/zilla/pull/1227) ([jfallows](https://github.com/jfallows))
+- Link checker [\#1216](https://github.com/aklivity/zilla/pull/1216) ([vordimous](https://github.com/vordimous))
+- Fix incorrect CRC combine in Kafka produce client [\#1214](https://github.com/aklivity/zilla/pull/1214) ([bmaidics](https://github.com/bmaidics))
+- Reduce compile warnings [\#1213](https://github.com/aklivity/zilla/pull/1213) ([jfallows](https://github.com/jfallows))
+- Eclipse IDE import maven projects [\#1212](https://github.com/aklivity/zilla/pull/1212) ([jfallows](https://github.com/jfallows))
+- Disable JVM class sharing to avoid error message during build [\#1210](https://github.com/aklivity/zilla/pull/1210) ([jfallows](https://github.com/jfallows))
+- Initial risingwave binding projects [\#1209](https://github.com/aklivity/zilla/pull/1209) ([jfallows](https://github.com/jfallows))
+- Ensure id encoding is consistent for encode and decode [\#1204](https://github.com/aklivity/zilla/pull/1204) ([jfallows](https://github.com/jfallows))
+- Update mqtt session stream to report correct origin id for zilla dump command [\#1203](https://github.com/aklivity/zilla/pull/1203) ([jfallows](https://github.com/jfallows))
+- Support pgsql binding [\#1200](https://github.com/aklivity/zilla/pull/1200) ([akrambek](https://github.com/akrambek))
+- Initial pgsql binding projects [\#1198](https://github.com/aklivity/zilla/pull/1198) ([jfallows](https://github.com/jfallows))
+- Fix: Using `asyncapi client` binding trigger NPE & crashes Zilla [\#1197](https://github.com/aklivity/zilla/pull/1197) ([ankitk-me](https://github.com/ankitk-me))
+- Compute kafka produce checksum without staging headers [\#1196](https://github.com/aklivity/zilla/pull/1196) ([jfallows](https://github.com/jfallows))
+- Allow content-length header with h2c upgrade [\#1194](https://github.com/aklivity/zilla/pull/1194) ([jfallows](https://github.com/jfallows))
+- Kafka cache client: mark entry dirty at flush before notifying the server to process [\#1193](https://github.com/aklivity/zilla/pull/1193) ([bmaidics](https://github.com/bmaidics))
+- Ensure streams are cleaned up on authentication failure… [\#1191](https://github.com/aklivity/zilla/pull/1191) ([jfallows](https://github.com/jfallows))
+
+## [0.9.92](https://github.com/aklivity/zilla/tree/0.9.92) (2024-08-13)
+
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.91...0.9.92)
 
 **Implemented enhancements:**
 
 - Support `extract-key` kafka message transform [\#1176](https://github.com/aklivity/zilla/issues/1176)
 
+**Merged pull requests:**
+
+- Align subject names when using inline catalog [\#1190](https://github.com/aklivity/zilla/pull/1190) ([jfallows](https://github.com/jfallows))
+- Support extract-key kafka message transform  [\#1183](https://github.com/aklivity/zilla/pull/1183) ([akrambek](https://github.com/akrambek))
+
 ## [0.9.91](https://github.com/aklivity/zilla/tree/0.9.91) (2024-08-10)
 
 [Full Changelog](https://github.com/aklivity/zilla/compare/0.9.90...0.9.91)

README.md

@@ -38,7 +38,7 @@ Use **Zilla** as a:
 | [Async workflows for sync microservices →](https://github.com/aklivity/zilla-examples/tree/main/http.kafka.async) | Make request-response microservice communication asynchronous by routing it over a pair of Kafka topics. |
 | [Create an event-mesh →](https://www.aklivity.io/post/end-to-end-streaming-between-grpc-services-via-kafka) | Integrate mesh and event-driven microservices by routing connectivity through Kafka. Make Kafka look like a gRPC/REST server or gRPC client. |
 | [Secure a Server Sent Event (SSE) API →](https://github.com/aklivity/zilla-examples/tree/main/sse.proxy.jwt) | Secure an SSE API by adding JWT-based Continous Authorization. |
-| [Validate MQTT via AsyncAPI →](https://github.com/aklivity/zilla-examples/tree/main/mqtt.proxy.asyncapi) | Enforce an AsyncAPI schema for messages going into an MQTT broker. |
+| [Validate MQTT via AsyncAPI →](https://github.com/aklivity/zilla-examples/tree/main/asyncapi.mqtt.kafka.proxy) | Enforce an AsyncAPI schema for messages going into an MQTT broker. |
 | **Much more!** | Check out all the [Zilla Demos](https://github.com/aklivity/zilla-demos) and [Zilla Examples](https://github.com/aklivity/zilla-examples). |
 
 ## Get started in 60 seconds

build/flyweight-maven-plugin/pom.xml

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

build/flyweight-maven-plugin/src/main/java/io/aklivity/zilla/build/maven/plugins/flyweight/internal/AbstractMojo.java

@@ -20,6 +20,8 @@
 import java.net.URI;
 import java.net.URL;
 import java.net.URLClassLoader;
+import java.nio.file.Files;
+import java.nio.file.Path;
 import java.util.LinkedList;
 import java.util.List;
 
@@ -65,11 +67,15 @@ ClassLoader createLoader() throws IOException
 
         try
         {
-            for (Object resourcePathEntry : project.getTestClasspathElements())
+            for (String classPathElement : project.getTestClasspathElements())
             {
-                File resourcePathFile = new File(resourcePathEntry.toString());
-                URI resourcePathURI = resourcePathFile.getAbsoluteFile().toURI();
-                resourcePath.add(URI.create(String.format("jar:%s!/META-INF/zilla/", resourcePathURI)).toURL());
+                Path classPathEntry = Path.of(classPathElement).toAbsolutePath();
+                URI classPathEntryURI = classPathEntry.toUri();
+                URI resourcePathEntryURI = Files.isDirectory(classPathEntry)
+                    ? classPathEntry.resolve("META-INF/zilla").toUri()
+                    : URI.create(String.format("jar:%s!/META-INF/zilla/", classPathEntryURI));
+                URL resourcePathEntry = resourcePathEntryURI.toURL();
+                resourcePath.add(resourcePathEntry);
             }
         }
         catch (DependencyResolutionRequiredException e)

build/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.92</version>
+    <version>0.9.93</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.92</version>
+    <version>0.9.93</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 
@@ -51,37 +51,37 @@
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-openapi</artifactId>
+      <artifactId>binding-echo</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-openapi-asyncapi</artifactId>
+      <artifactId>binding-fan</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-echo</artifactId>
+      <artifactId>binding-filesystem</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-fan</artifactId>
+      <artifactId>binding-http</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-filesystem</artifactId>
+      <artifactId>binding-http-filesystem</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-http</artifactId>
+      <artifactId>binding-http-kafka</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
@@ -91,6 +91,12 @@
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
+    <dependency>
+      <groupId>${project.groupId}</groupId>
+      <artifactId>binding-grpc-kafka</artifactId>
+      <version>${project.version}</version>
+      <scope>runtime</scope>
+    </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
       <artifactId>binding-kafka</artifactId>
@@ -99,7 +105,7 @@
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-proxy</artifactId>
+      <artifactId>binding-kafka-grpc</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
@@ -111,61 +117,67 @@
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-sse</artifactId>
+      <artifactId>binding-mqtt-kafka</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-tcp</artifactId>
+      <artifactId>binding-openapi</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-tls</artifactId>
+      <artifactId>binding-openapi-asyncapi</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-ws</artifactId>
+      <artifactId>binding-pgsql</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-http-filesystem</artifactId>
+      <artifactId>binding-proxy</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-http-kafka</artifactId>
+      <artifactId>binding-risingwave</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-grpc-kafka</artifactId>
+      <artifactId>binding-sse</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-mqtt-kafka</artifactId>
+      <artifactId>binding-sse-kafka</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-sse-kafka</artifactId>
+      <artifactId>binding-tcp</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>binding-kafka-grpc</artifactId>
+      <artifactId>binding-tls</artifactId>
+      <version>${project.version}</version>
+      <scope>runtime</scope>
+    </dependency>
+    <dependency>
+      <groupId>${project.groupId}</groupId>
+      <artifactId>binding-ws</artifactId>
       <version>${project.version}</version>
       <scope>runtime</scope>
     </dependency>
@@ -376,7 +388,7 @@
       <plugin>
         <groupId>io.fabric8</groupId>
         <artifactId>docker-maven-plugin</artifactId>
-        <version>0.43.2</version>
+        <version>0.45.0</version>
         <configuration>
           <filter>${*}</filter>
           <images combine.children="append">

cloud/docker-image/src/main/docker/zpm.json.template

@@ -29,7 +29,9 @@
     "io.aklivity.zilla:binding-mqtt-kafka",
     "io.aklivity.zilla:binding-openapi",
     "io.aklivity.zilla:binding-openapi-asyncapi",
+    "io.aklivity.zilla:binding-pgsql",
     "io.aklivity.zilla:binding-proxy",
+    "io.aklivity.zilla:binding-risingwave",
     "io.aklivity.zilla:binding-sse",
     "io.aklivity.zilla:binding-sse-kafka",
     "io.aklivity.zilla:binding-tcp",

cloud/helm-chart/pom.xml

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

conf/src/main/resources/io/aklivity/zilla/conf/checkstyle/configuration.xml

@@ -18,6 +18,10 @@
 <!DOCTYPE module PUBLIC "-//Puppy Crawl//DTD Check Configuration 1.2//EN"
         "http://www.puppycrawl.com/dtds/configuration_1_2.dtd">
 <module name="Checker">
+    <module name="BeforeExecutionExclusionFileFilter">
+        <property name="fileNamePattern" value="target/generated-.*sources/.*"/>
+    </module>
+
     <module name="SeverityMatchFilter">
         <property name="severity" value="info"/>
         <property name="acceptOnMatch" value="false"/>

conf/src/main/resources/io/aklivity/zilla/conf/checkstyle/suppressions.xml

@@ -21,6 +21,4 @@
 <suppressions>
     <suppress checks="Javadoc.*" files=".+[\\/]internal[\\/].+" />
     <suppress checks="Javadoc.*" files=".+[\\/]src[\\/]test[\\/].+" />
-    <suppress checks=".*" files=".+[\\/]target[\\/]generated-sources[\\/].+" />
-    <suppress checks=".*" files=".+[\\/]target[\\/]generated-test-sources[\\/].+" />
 </suppressions>

incubator/binding-amqp.spec/pom.xml

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