Merge branch 'release/0.9.56'

aklivity · Oct 31, 2023 · ac5b6fe · ac5b6fe
2 parents e740249 + 44759fb
commit ac5b6fe
Show file tree

Hide file tree

Showing 218 changed files with 5,504 additions and 527 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,7 +2,58 @@
 
 ## [Unreleased](https://github.com/aklivity/zilla/tree/HEAD)
 
-[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.54...HEAD)
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.55...HEAD)
+
+**Implemented enhancements:**
+
+- Support `extraEnv` in helm chart [\#520](https://github.com/aklivity/zilla/issues/520)
+- `kubernetes autoscaling` feature \(enhanced\) [\#518](https://github.com/aklivity/zilla/issues/518)
+- Shard MQTT topic space for client-id specific subset [\#427](https://github.com/aklivity/zilla/issues/427)
+- Distribute MQTT topic space across different Kafka topics [\#426](https://github.com/aklivity/zilla/issues/426)
+- `AsyncAPI` integration \(baseline\) [\#257](https://github.com/aklivity/zilla/issues/257)
+- `OpenAPI` integration \(baseline\) [\#255](https://github.com/aklivity/zilla/issues/255)
+- `mqtt-kafka` feature \(baseline\) [\#190](https://github.com/aklivity/zilla/issues/190)
+- `telemetry metrics` feature \(baseline\) [\#188](https://github.com/aklivity/zilla/issues/188)
+- `grpc-kafka` feature \(baseline\) [\#183](https://github.com/aklivity/zilla/issues/183)
+
+**Fixed bugs:**
+
+- Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 [\#551](https://github.com/aklivity/zilla/issues/551)
+- BudgetDebitor fails to claim budget after sometime [\#548](https://github.com/aklivity/zilla/issues/548)
+- Unexpected flush causes NPE in connection pool [\#546](https://github.com/aklivity/zilla/issues/546)
+- \[Consumer Group\] Race  condition while joining simultaneously to the same group id [\#542](https://github.com/aklivity/zilla/issues/542)
+- MQTT client connections cause errors/crashes [\#527](https://github.com/aklivity/zilla/issues/527)
+- Sporadic github action build failures [\#526](https://github.com/aklivity/zilla/issues/526)
+- Unable to write to streams buffer under bidi-stream [\#368](https://github.com/aklivity/zilla/issues/368)
+- Fix flow control bug in mqtt-kakfa publish [\#524](https://github.com/aklivity/zilla/pull/524) ([bmaidics](https://github.com/bmaidics))
+
+**Closed issues:**
+
+- Feature: Adding contributors section to the README.md file. [\#545](https://github.com/aklivity/zilla/issues/545)
+- gRPC method call doesn't respond when status code is not OK [\#504](https://github.com/aklivity/zilla/issues/504)
+
+**Merged pull requests:**
+
+- Fix mqtt connect decoding bug when remainingLenght.size \> 1 [\#554](https://github.com/aklivity/zilla/pull/554) ([bmaidics](https://github.com/bmaidics))
+- Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 [\#552](https://github.com/aklivity/zilla/pull/552) ([akrambek](https://github.com/akrambek))
+- Don't send window before connection budgetId is assigned [\#549](https://github.com/aklivity/zilla/pull/549) ([akrambek](https://github.com/akrambek))
+- Use coordinator member list to check if the heartbeat is allowed [\#547](https://github.com/aklivity/zilla/pull/547) ([akrambek](https://github.com/akrambek))
+- Retry sync group request if there is inflight request [\#543](https://github.com/aklivity/zilla/pull/543) ([akrambek](https://github.com/akrambek))
+- Add "Back to Top" in Readme.md [\#539](https://github.com/aklivity/zilla/pull/539) ([PrajwalGraj](https://github.com/PrajwalGraj))
+- Create an appropriate buffer with the size that accommodates signal frame payload [\#537](https://github.com/aklivity/zilla/pull/537) ([akrambek](https://github.com/akrambek))
+- Adjust padding for larger message header and don't include partial data while computing crc32c  [\#536](https://github.com/aklivity/zilla/pull/536) ([akrambek](https://github.com/akrambek))
+- Fix dump command to truncate output file if exists [\#534](https://github.com/aklivity/zilla/pull/534) ([attilakreiner](https://github.com/attilakreiner))
+- fix typos in README.md [\#532](https://github.com/aklivity/zilla/pull/532) ([shresthasurav](https://github.com/shresthasurav))
+- Fixed a typo in README.md [\#529](https://github.com/aklivity/zilla/pull/529) ([saakshii12](https://github.com/saakshii12))
+- Sporadic github action build failure fix [\#522](https://github.com/aklivity/zilla/pull/522) ([akrambek](https://github.com/akrambek))
+- Propagate gRPC status code when not ok [\#519](https://github.com/aklivity/zilla/pull/519) ([jfallows](https://github.com/jfallows))
+- Add extraEnv to Deployment in the helm chart [\#511](https://github.com/aklivity/zilla/pull/511) ([attilakreiner](https://github.com/attilakreiner))
+- Client topic space [\#507](https://github.com/aklivity/zilla/pull/507) ([bmaidics](https://github.com/bmaidics))
+- Mqtt topic space [\#493](https://github.com/aklivity/zilla/pull/493) ([bmaidics](https://github.com/bmaidics))
+
+## [0.9.55](https://github.com/aklivity/zilla/tree/0.9.55) (2023-10-11)
+
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.54...0.9.55)
 
 **Implemented enhancements:**
 
@@ -226,7 +277,7 @@
 
 **Implemented enhancements:**
 
-- `kubernetes autoscaling` feature [\#189](https://github.com/aklivity/zilla/issues/189)
+- `kubernetes autoscaling` feature \(baseline\) [\#189](https://github.com/aklivity/zilla/issues/189)
 
 **Closed issues:**
 
@@ -525,7 +576,7 @@
 **Fixed bugs:**
 
 - Error running http.kafka.oneway from zilla-examples [\#117](https://github.com/aklivity/zilla/issues/117)
-- Zillla build fails on timeout [\#102](https://github.com/aklivity/zilla/issues/102)
+- Zilla build fails on timeout [\#102](https://github.com/aklivity/zilla/issues/102)
 
 **Merged pull requests:**
 

diff --git a/README.md b/README.md
@@ -1,3 +1,4 @@
+<div id="top"></div>
 <div align="center">
   <img src="./assets/zilla-rings@2x.png" height="250">
 </div>
@@ -61,7 +62,7 @@ Returns an `etag` header with `HTTP` response. Supports conditional `GET if-none
 
 - [x] **Filtering** — Streams messages from a Kafka topic, filtered by message key and/or headers, with key and/or header values extracted from segments of the `HTTP` path if needed.
 - [x] **Reliable Delivery** — Supports `event-id` and `last-event-id` header to recover from an interrupted stream without message loss, and without the client needing to acknowledge message receipt.
-- [x] **Continous Authorization** — Supports a `challenge` event, triggering the client to send up-to-date authorization credentials, such as JWT token, before expiration. The response stream is terminated if the authorization expires. Multiple SSE streams on the same `HTTP/2` connection and authorized by the same JWT token can be reauthorized by a single `challenge` event response.
+- [x] **Continuous Authorization** — Supports a `challenge` event, triggering the client to send up-to-date authorization credentials, such as JWT token, before expiration. The response stream is terminated if the authorization expires. Multiple SSE streams on the same `HTTP/2` connection and authorized by the same JWT token can be reauthorized by a single `challenge` event response.
 
 ### <a name="grpc-kafka-proxying"> gRPC-Kafka Proxying
 
@@ -86,7 +87,7 @@ Returns an `etag` header with `HTTP` response. Supports conditional `GET if-none
 - [x] **Filtering** — Local cache indexes message key and headers upon retrieval from Kafka, supporting efficiently filtered reads from cached topics.
 - [x] **Fan-in, Fan-out** — Local cache uses a small number of connections to interact with Kafka brokers, independent of the number of connected clients.
 - [x] **Authorization** — Specific routed topics can be guarded to enforce required client privileges.
-- [x] **Helm Chart** — Generic Zilla Helm chart avaliable.
+- [x] **Helm Chart** — Generic Zilla Helm chart available.
 - [x] **Auto-reconfigure** — Detect changes in `zilla.yaml` and reconfigure Zilla automatically.
 - [x] **Prometheus Integration** — Export Zilla metrics to Prometheus for observability and auto-scaling.
 - [x] **Declarative Configuration** — API mappings and endpoints inside Zilla are declaratively configured via YAML.
@@ -175,7 +176,7 @@ Looking to contribute to Zilla? Check out the [Contributing to Zilla](./.github/
 ✨We value all contributions, whether it is source code, documentation, bug reports, feature requests or feedback!
 
 ## <a name="license"> License
-Zilla is made available under the [Aklivity Community License](./LICENSE-AklivityCommunity). This is an open source-derived license that gives you the freedom to deploy, modify and run Zilla as you see fit, as long as you are not turning into a commercialized “as-a-service” offering. Running Zilla in the cloud for your own workloads, production or not, is completely fine.
+Zilla is made available under the [Aklivity Community License](./LICENSE-AklivityCommunity). This is an open source-derived license that gives you the freedom to deploy, modify and run Zilla as you see fit, as long as you are not turning into a standalone commercialized “Zilla-as-a-service” offering. Running Zilla in the cloud for your own workloads, production or not, is completely fine.
 
 
 <!-- Links -->
@@ -188,3 +189,5 @@ Zilla is made available under the [Aklivity Community License](./LICENSE-Aklivit
 [release-latest-image]: https://img.shields.io/github/v/tag/aklivity/zilla?label=release
 [release-latest]: https://github.com/aklivity/zilla/pkgs/container/zilla
 [zilla-roadmap]: https://github.com/orgs/aklivity/projects/4/views/1
+
+<p align="right">(<a href="#top">🔼 Back to top</a>)</p>
diff --git a/build/flyweight-maven-plugin/pom.xml b/build/flyweight-maven-plugin/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>build</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/build/pom.xml b/build/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/cloud/docker-image/pom.xml b/cloud/docker-image/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/cloud/helm-chart/pom.xml b/cloud/helm-chart/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/cloud/helm-chart/src/main/helm/templates/deployment.yaml b/cloud/helm-chart/src/main/helm/templates/deployment.yaml
@@ -56,6 +56,9 @@ spec:
             - name: {{ $env.name }}
               value: {{ $env.value }}
           {{- end }}
+          {{- if .Values.extraEnv }}
+          {{- toYaml .Values.extraEnv | nindent 12 }}
+          {{- end }}
           image: "{{ .Values.image.repository }}:{{ .Values.image.tag | default .Chart.AppVersion }}"
           imagePullPolicy: {{ .Values.image.pullPolicy }}
           ports:

diff --git a/cloud/helm-chart/src/main/helm/values.yaml b/cloud/helm-chart/src/main/helm/values.yaml
@@ -34,7 +34,7 @@ readinessProbePort: 0
 initContainers: []
 
 args: ["start", "-v", "-e"]
-env: []
+extraEnv: []
 configPath: /etc/zilla
 configMaps: {}
 secrets: {}

diff --git a/cloud/pom.xml b/cloud/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/conf/pom.xml b/conf/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/binding-amqp.spec/pom.xml b/incubator/binding-amqp.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/binding-amqp/pom.xml b/incubator/binding-amqp/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/catalog-inline.spec/pom.xml b/incubator/catalog-inline.spec/pom.xml
@@ -8,7 +8,7 @@
     <parent>
         <groupId>io.aklivity.zilla</groupId>
         <artifactId>incubator</artifactId>
-        <version>0.9.55</version>
+        <version>0.9.56</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

diff --git a/incubator/catalog-inline/pom.xml b/incubator/catalog-inline/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>io.aklivity.zilla</groupId>
         <artifactId>incubator</artifactId>
-        <version>0.9.55</version>
+        <version>0.9.56</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

diff --git a/incubator/catalog-schema-registry.spec/pom.xml b/incubator/catalog-schema-registry.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/catalog-schema-registry/pom.xml b/incubator/catalog-schema-registry/pom.xml
@@ -6,7 +6,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/command-dump/pom.xml b/incubator/command-dump/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/...c/main/java/io/aklivity/zilla/runtime/command/dump/internal/airline/ZillaDumpCommand.java b/...c/main/java/io/aklivity/zilla/runtime/command/dump/internal/airline/ZillaDumpCommand.java
@@ -15,8 +15,9 @@
 package io.aklivity.zilla.runtime.command.dump.internal.airline;
 
 import static java.lang.Integer.parseInt;
-import static java.nio.file.StandardOpenOption.APPEND;
 import static java.nio.file.StandardOpenOption.CREATE;
+import static java.nio.file.StandardOpenOption.TRUNCATE_EXISTING;
+import static java.nio.file.StandardOpenOption.WRITE;
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import static org.agrona.LangUtil.rethrowUnchecked;
 
@@ -167,7 +168,7 @@ public void run()
         final LongPredicate filter = filtered.isEmpty() ? b -> true : filtered::contains;
 
         try (Stream<Path> files = Files.walk(directory, 3);
-            WritableByteChannel writer = Files.newByteChannel(output, CREATE, APPEND))
+            WritableByteChannel writer = Files.newByteChannel(output, CREATE, WRITE, TRUNCATE_EXISTING))
         {
             final RingBufferSpy[] streamBuffers = files
                 .filter(this::isStreamsFile)

diff --git a/incubator/command-generate/pom.xml b/incubator/command-generate/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/command-log/pom.xml b/incubator/command-log/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/command-tune/pom.xml b/incubator/command-tune/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/exporter-otlp.spec/pom.xml b/incubator/exporter-otlp.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/exporter-otlp/pom.xml b/incubator/exporter-otlp/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/pom.xml b/incubator/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/validator-avro.spec/pom.xml b/incubator/validator-avro.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/validator-avro/pom.xml b/incubator/validator-avro/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/validator-core.spec/pom.xml b/incubator/validator-core.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/validator-core/pom.xml b/incubator/validator-core/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/validator-json.spec/pom.xml b/incubator/validator-json.spec/pom.xml
@@ -8,7 +8,7 @@
 <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
 </parent>
 

diff --git a/incubator/validator-json/pom.xml b/incubator/validator-json/pom.xml
@@ -6,7 +6,7 @@
 <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
 </parent>
 

diff --git a/manager/pom.xml b/manager/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.55</version>
+    <version>0.9.56</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/pom.xml b/pom.xml
@@ -7,7 +7,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>io.aklivity.zilla</groupId>
   <artifactId>zilla</artifactId>
-  <version>0.9.55</version>
+  <version>0.9.56</version>
   <packaging>pom</packaging>
   <name>zilla</name>
   <url>https://github.com/aklivity/zilla</url>