0.9.62

Changelog

0.9.62 (2023-12-13)

Full Changelog

Closed issues:

• MQTT sessions don't show up in Redpanda #585

Merged pull requests:

• Reinitiate initialId and replyId on mqtt session reconnection #636 (akrambek)
• Support ability to connect to specific kafka cluster node hostname #633 (akrambek)
• Zpm install instrument #632 (jfallows)
• Bump alpine from 3.18.5 to 3.19.0 in /cloud/docker-image/src/main/docker/release #626 (dependabot[bot])

0.9.61 (2023-12-10)

Full Changelog

Implemented enhancements:

• Kafka GRPC consumer Group Support #597
• Integrate Schema Registry / Karapace #404
• Apply typed schema to cached messages; kafka cache fetch server #314
• schema-registry feature (baseline) #265
• Enhance inspection of internal streams #154

Fixed bugs:

• Group Coordinator sasl scram doesn't have complete full handshake #624
• Follow kafka consumer protocol data structure for userdata parsing #617
• WebSocket inbound ping frames are rejected #606
• Fix encoding error when no properties defined by the client #627 (bmaidics)

Closed issues:

• MQTT client is disconnected and cannot reconnect after sending message #623
• Use affinity and Long2ObjectHashmap instead of clientId #432

Merged pull requests:

• WebSocket inbound ping frames support #629 (akrambek)
• Split qos0 and qos12 publish streams, add ISR #628 (bmaidics)
• Update kafka client group session timeout defaults #625 (jfallows)
• Fix handeling sasl scram error in group coordinator #622 (akrambek)
• Include kafka client id consistently in all kafka protocol encoders #621 (jfallows)
• Follow kafka consumer protocol data structure for userdata parsing #618 (akrambek)
• Kafka GRPC consumer Group Support #598 (akrambek)
• Enhance inspection of internal streams #596 (attilakreiner)

0.9.60 (2023-12-05)

Full Changelog

Implemented enhancements:

• MQTT publish QoS 1 as Kafka produce with acks in_sync_replicas #604
• MQTT subscribe QoS 2 as stateful Kafka fetch with consumerId for message delivery retry #603
• MQTT subscribe QoS 1 as stateful Kafka fetch with consumerId for message delivery retry #602
• Include metadata in merge reply begin ex #601
• Consumer group message acknowledgement support #588
• Support mqtt protocol v3.1.1 #541
• Generate http server request validators from OpenAPI specification #459
• MQTT 3.1.1 implementation #582 (bmaidics)

Fixed bugs:

• the tls binding throws NPE if there are no options defined #612
• Offset commit request should have next offset instead of consumer message offset #592
• group.min.session.timeout.ms is null using zilla in front of redpanda #581
• java.lang.IllegalStateException: missing file for budgets : /var/run/zilla/budgets127 #578

Closed issues:

• prometheus schema Port and tcp schema Port have different validation #569
• zilla:correlation-id header sort #508

Merged pull requests:

• Fix typo #616 (bmaidics)
• Wait for replyFlush at commit before closing retained stream #615 (bmaidics)
• Fix qos12 #614 (bmaidics)
• Start from historical messages if no consumer offsets were committed #613 (akrambek)
• Tls binding options not required #611 (jfallows)
• Fix not closing retained stream #610 (bmaidics)
• Fix mqtt-kakfa qos1,2 issues #609 (bmaidics)
• Bump alpine from 3.18.4 to 3.18.5 in /cloud/docker-image/src/main/docker/release #600 (dependabot[bot])
• Include metadata and partitionOffset into merge reply begin #599 (akrambek)
• Update Helm chart Zilla description #595 (vordimous)
• Bump actions/setup-java from 3 to 4 #594 (dependabot[bot])
• Offset commit fixes #593 (akrambek)
• Implement QoS 1 and QoS 2 #589 (bmaidics)
• Fix prometheus exporter schema #587 (attilakreiner)
• Include validation in the openapi.http.proxy generator #586 (attilakreiner)
• Fix mergedReplyBudgetId #579 (attilakreiner)
• MQTT 3.1.1 support - specs #570 (bmaidics)
• Consumer group message acknowledgement support #538 (akrambek)
• Include data payload as hex in the output of log command #523 (attilakreiner)

0.9.59 (2023-11-21)

Full Changelog

Implemented enhancements:

• Generate http server request validators from AsyncAPI specification #460

Fixed bugs:

• MQTT topic routing doesn't correctly reject pub/sub requests #572
• Fix producing empty message to retained topic #577 (bmaidics)
• Fix MQTT topic routing doesn't correctly reject pub/sub requests #573 (bmaidics)

Closed issues:

• Empty messages on retained topic for all MQTT messages #575
• [DOCS] Fix typos in README file #540

Merged pull requests:

• Consumer group session timeout defaults #584 (jfallows)
• Fix json validator to also accept arrays #576 (attilakreiner)
• Include validation in the asyncapi.http.proxy generator #574 (attilakreiner)

0.9.58 (2023-11-13)

Full Changelog

Implemented enhancements:

• Integrate http binding with validators [#455](ht...

0.9.61

Changelog

0.9.61 (2023-12-10)

Full Changelog

Implemented enhancements:

• Kafka GRPC consumer Group Support #597
• Integrate Schema Registry / Karapace #404
• Apply typed schema to cached messages; kafka cache fetch server #314
• schema-registry feature (baseline) #265
• Enhance inspection of internal streams #154

Fixed bugs:

• Group Coordinator sasl scram doesn't have complete full handshake #624
• Follow kafka consumer protocol data structure for userdata parsing #617
• WebSocket inbound ping frames are rejected #606
• Fix encoding error when no properties defined by the client #627 (bmaidics)

Closed issues:

• MQTT client is disconnected and cannot reconnect after sending message #623
• Use affinity and Long2ObjectHashmap instead of clientId #432

Merged pull requests:

• WebSocket inbound ping frames support #629 (akrambek)
• Split qos0 and qos12 publish streams, add ISR #628 (bmaidics)
• Update kafka client group session timeout defaults #625 (jfallows)
• Fix handeling sasl scram error in group coordinator #622 (akrambek)
• Include kafka client id consistently in all kafka protocol encoders #621 (jfallows)
• Follow kafka consumer protocol data structure for userdata parsing #618 (akrambek)
• Kafka GRPC consumer Group Support #598 (akrambek)
• Enhance inspection of internal streams #596 (attilakreiner)

0.9.60 (2023-12-05)

Full Changelog

Implemented enhancements:

• MQTT publish QoS 1 as Kafka produce with acks in_sync_replicas #604
• MQTT subscribe QoS 2 as stateful Kafka fetch with consumerId for message delivery retry #603
• MQTT subscribe QoS 1 as stateful Kafka fetch with consumerId for message delivery retry #602
• Include metadata in merge reply begin ex #601
• Consumer group message acknowledgement support #588
• Support mqtt protocol v3.1.1 #541
• Generate http server request validators from OpenAPI specification #459
• MQTT 3.1.1 implementation #582 (bmaidics)

Fixed bugs:

• the tls binding throws NPE if there are no options defined #612
• Offset commit request should have next offset instead of consumer message offset #592
• group.min.session.timeout.ms is null using zilla in front of redpanda #581
• java.lang.IllegalStateException: missing file for budgets : /var/run/zilla/budgets127 #578

Closed issues:

• prometheus schema Port and tcp schema Port have different validation #569
• zilla:correlation-id header sort #508

Merged pull requests:

• Fix typo #616 (bmaidics)
• Wait for replyFlush at commit before closing retained stream #615 (bmaidics)
• Fix qos12 #614 (bmaidics)
• Start from historical messages if no consumer offsets were committed #613 (akrambek)
• Tls binding options not required #611 (jfallows)
• Fix not closing retained stream #610 (bmaidics)
• Fix mqtt-kakfa qos1,2 issues #609 (bmaidics)
• Bump alpine from 3.18.4 to 3.18.5 in /cloud/docker-image/src/main/docker/release #600 (dependabot[bot])
• Include metadata and partitionOffset into merge reply begin #599 (akrambek)
• Update Helm chart Zilla description #595 (vordimous)
• Bump actions/setup-java from 3 to 4 #594 (dependabot[bot])
• Offset commit fixes #593 (akrambek)
• Implement QoS 1 and QoS 2 #589 (bmaidics)
• Fix prometheus exporter schema #587 (attilakreiner)
• Include validation in the openapi.http.proxy generator #586 (attilakreiner)
• Fix mergedReplyBudgetId #579 (attilakreiner)
• MQTT 3.1.1 support - specs #570 (bmaidics)
• Consumer group message acknowledgement support #538 (akrambek)
• Include data payload as hex in the output of log command #523 (attilakreiner)

0.9.59 (2023-11-21)

Full Changelog

Implemented enhancements:

• Generate http server request validators from AsyncAPI specification #460

Fixed bugs:

• MQTT topic routing doesn't correctly reject pub/sub requests #572
• Fix producing empty message to retained topic #577 (bmaidics)
• Fix MQTT topic routing doesn't correctly reject pub/sub requests #573 (bmaidics)

Closed issues:

• Empty messages on retained topic for all MQTT messages #575
• [DOCS] Fix typos in README file #540

Merged pull requests:

• Consumer group session timeout defaults #584 (jfallows)
• Fix json validator to also accept arrays #576 (attilakreiner)
• Include validation in the asyncapi.http.proxy generator #574 (attilakreiner)

0.9.58 (2023-11-13)

Full Changelog

Implemented enhancements:

• Integrate http binding with validators #455

Fixed bugs:

• [MQTT-Kafka] Exception runtime.binding.mqtt.kafka.internal.types.MqttExpirySignalFW.wrap(MqttExpirySignalFW.java:45) #563
• Running mqtt benchmark triggers mqtt exception #488
• Fix IndexOutOfBoundsException when receiving expiry signal #567 (bmaidics)

Merged pull requests:

• Integrate http binding with validators #571 (attilakreiner)
• Fix flow conrol bug + indexoutofbound exception #568 (bmaidics)

0.9.57 (2023-11-04)

[Full Changelog](https://github.com/akl...

0.9.60

Changelog

0.9.60 (2023-12-05)

Full Changelog

Implemented enhancements:

• MQTT publish QoS 1 as Kafka produce with acks in_sync_replicas #604
• MQTT subscribe QoS 2 as stateful Kafka fetch with consumerId for message delivery retry #603
• MQTT subscribe QoS 1 as stateful Kafka fetch with consumerId for message delivery retry #602
• Include metadata in merge reply begin ex #601
• Consumer group message acknowledgement support #588
• Support mqtt protocol v3.1.1 #541
• Generate http server request validators from OpenAPI specification #459
• MQTT 3.1.1 implementation #582 (bmaidics)

Fixed bugs:

• the tls binding throws NPE if there are no options defined #612
• Offset commit request should have next offset instead of consumer message offset #592
• group.min.session.timeout.ms is null using zilla in front of redpanda #581
• java.lang.IllegalStateException: missing file for budgets : /var/run/zilla/budgets127 #578

Closed issues:

• prometheus schema Port and tcp schema Port have different validation #569
• zilla:correlation-id header sort #508

Merged pull requests:

• Fix typo #616 (bmaidics)
• Wait for replyFlush at commit before closing retained stream #615 (bmaidics)
• Fix qos12 #614 (bmaidics)
• Start from historical messages if no consumer offsets were committed #613 (akrambek)
• Tls binding options not required #611 (jfallows)
• Fix not closing retained stream #610 (bmaidics)
• Fix mqtt-kakfa qos1,2 issues #609 (bmaidics)
• Bump alpine from 3.18.4 to 3.18.5 in /cloud/docker-image/src/main/docker/release #600 (dependabot[bot])
• Include metadata and partitionOffset into merge reply begin #599 (akrambek)
• Update Helm chart Zilla description #595 (vordimous)
• Bump actions/setup-java from 3 to 4 #594 (dependabot[bot])
• Offset commit fixes #593 (akrambek)
• Implement QoS 1 and QoS 2 #589 (bmaidics)
• Fix prometheus exporter schema #587 (attilakreiner)
• Include validation in the openapi.http.proxy generator #586 (attilakreiner)
• Fix mergedReplyBudgetId #579 (attilakreiner)
• MQTT 3.1.1 support - specs #570 (bmaidics)
• Consumer group message acknowledgement support #538 (akrambek)
• Include data payload as hex in the output of log command #523 (attilakreiner)

0.9.59 (2023-11-21)

Full Changelog

Implemented enhancements:

• Generate http server request validators from AsyncAPI specification #460

Fixed bugs:

• MQTT topic routing doesn't correctly reject pub/sub requests #572
• Fix producing empty message to retained topic #577 (bmaidics)
• Fix MQTT topic routing doesn't correctly reject pub/sub requests #573 (bmaidics)

Closed issues:

• Empty messages on retained topic for all MQTT messages #575
• [DOCS] Fix typos in README file #540

Merged pull requests:

• Consumer group session timeout defaults #584 (jfallows)
• Fix json validator to also accept arrays #576 (attilakreiner)
• Include validation in the asyncapi.http.proxy generator #574 (attilakreiner)

0.9.58 (2023-11-13)

Full Changelog

Implemented enhancements:

• Integrate http binding with validators #455

Fixed bugs:

• [MQTT-Kafka] Exception runtime.binding.mqtt.kafka.internal.types.MqttExpirySignalFW.wrap(MqttExpirySignalFW.java:45) #563
• Running mqtt benchmark triggers mqtt exception #488
• Fix IndexOutOfBoundsException when receiving expiry signal #567 (bmaidics)

Merged pull requests:

• Integrate http binding with validators #571 (attilakreiner)
• Fix flow conrol bug + indexoutofbound exception #568 (bmaidics)

0.9.57 (2023-11-04)

Full Changelog

Fixed bugs:

• [Connection Pool] binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientConnection.doConnectionWindow(KafkaClientConnectionPool.java:1318) #565
• [MQTT-Kafka] Randomly closing the connection in the middle of produce triggers the exception #559
• Gracefully handle out of slot exception in kafka cache client produce #558
• [Connection Pool] Signaling can trigger exception #557
• http-kafka fetch binding returns malformed JSON when the payload is large #528

Merged pull requests:

• Ignore removing ack before receiving complete response even if the stream reply is closed #566 (akrambek)
• Fix bootstrap test #562 (bmaidics)
• Gracefully handle out of slot exception in kafka client produce #561 (akrambek)
• Better handling negative edge cases in the connection pool #560 (akrambek)
• Handle fragmentation in HttpFetchManyProxy #556 (akrambek)
• Added Contributors section in readme #553 (DhanushNehru)
• Fix: Added Contribution Section to Readme #550 (Kalyanimhala)

0.9.56 (2023-10-31)

Full Changelog

Implemented enhancements:

• Support extraEnv in helm chart #520
• kubernetes autoscaling feature (enhanced) #518
• Shard MQTT topic space for client-id specific subset #427
• Distribute MQTT topic space across different Kafka topics #426
• AsyncAPI integration (baseline) #257
• OpenAPI integration (baseline) #255
• mqtt-kafka feature (ba...

0.9.59

Changelog

0.9.59 (2023-11-21)

Full Changelog

Implemented enhancements:

• Generate http server request validators from AsyncAPI specification #460

Fixed bugs:

• MQTT topic routing doesn't correctly reject pub/sub requests #572
• Fix producing empty message to retained topic #577 (bmaidics)
• Fix MQTT topic routing doesn't correctly reject pub/sub requests #573 (bmaidics)

Closed issues:

• Empty messages on retained topic for all MQTT messages #575
• [DOCS] Fix typos in README file #540

Merged pull requests:

• Consumer group session timeout defaults #584 (jfallows)
• Fix json validator to also accept arrays #576 (attilakreiner)
• Include validation in the asyncapi.http.proxy generator #574 (attilakreiner)

0.9.58 (2023-11-13)

Full Changelog

Implemented enhancements:

• Integrate http binding with validators #455

Fixed bugs:

• [MQTT-Kafka] Exception runtime.binding.mqtt.kafka.internal.types.MqttExpirySignalFW.wrap(MqttExpirySignalFW.java:45) #563
• Running mqtt benchmark triggers mqtt exception #488
• Fix IndexOutOfBoundsException when receiving expiry signal #567 (bmaidics)

Merged pull requests:

• Integrate http binding with validators #571 (attilakreiner)
• Fix flow conrol bug + indexoutofbound exception #568 (bmaidics)

0.9.57 (2023-11-04)

Full Changelog

Fixed bugs:

• [Connection Pool] binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientConnection.doConnectionWindow(KafkaClientConnectionPool.java:1318) #565
• [MQTT-Kafka] Randomly closing the connection in the middle of produce triggers the exception #559
• Gracefully handle out of slot exception in kafka cache client produce #558
• [Connection Pool] Signaling can trigger exception #557
• http-kafka fetch binding returns malformed JSON when the payload is large #528

Merged pull requests:

• Ignore removing ack before receiving complete response even if the stream reply is closed #566 (akrambek)
• Fix bootstrap test #562 (bmaidics)
• Gracefully handle out of slot exception in kafka client produce #561 (akrambek)
• Better handling negative edge cases in the connection pool #560 (akrambek)
• Handle fragmentation in HttpFetchManyProxy #556 (akrambek)
• Added Contributors section in readme #553 (DhanushNehru)
• Fix: Added Contribution Section to Readme #550 (Kalyanimhala)

0.9.56 (2023-10-31)

Full Changelog

Implemented enhancements:

• Support extraEnv in helm chart #520
• kubernetes autoscaling feature (enhanced) #518
• Shard MQTT topic space for client-id specific subset #427
• Distribute MQTT topic space across different Kafka topics #426
• AsyncAPI integration (baseline) #257
• OpenAPI integration (baseline) #255
• mqtt-kafka feature (baseline) #190
• telemetry metrics feature (baseline) #188
• grpc-kafka feature (baseline) #183

Fixed bugs:

• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #551
• BudgetDebitor fails to claim budget after sometime #548
• Unexpected flush causes NPE in connection pool #546
• [Consumer Group] Race condition while joining simultaneously to the same group id #542
• MQTT client connections cause errors/crashes #527
• Sporadic github action build failures #526
• Unable to write to streams buffer under bidi-stream #368
• Fix flow control bug in mqtt-kakfa publish #524 (bmaidics)

Closed issues:

• Feature: Adding contributors section to the README.md file. #545
• gRPC method call doesn't respond when status code is not OK #504

Merged pull requests:

• Fix mqtt connect decoding bug when remainingLenght.size > 1 #554 (bmaidics)
• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #552 (akrambek)
• Don't send window before connection budgetId is assigned #549 (akrambek)
• Use coordinator member list to check if the heartbeat is allowed #547 (akrambek)
• Retry sync group request if there is inflight request #543 (akrambek)
• Add "Back to Top" in Readme.md #539 (PrajwalGraj)
• Create an appropriate buffer with the size that accommodates signal frame payload #537 (akrambek)
• Adjust padding for larger message header and don't include partial data while computing crc32c #536 (akrambek)
• Fix dump command to truncate output file if exists #534 (attilakreiner)
• fix typos in README.md #532 (shresthasurav)
• Fixed a typo in README.md #529 (saakshii12)
• Sporadic github action build failure fix #522 (akrambek)
• Propagate gRPC status code when not ok #519 (jfallows)
• Add extraEnv to Deployment in the helm chart #511 (attilakreiner)
• Client topic space #507 (bmaidics)
• Mqtt topic space #493 (bmaidics)

0.9.55 (2023-10-11)

Full Changelog

Implemented enhancements:

• Use 1-1 helm chart versioning strategy #487
• Generate mqtt server publish validators from AsyncAPI specification #461
• Integrate mqtt binding with validators #456
• Implement json validator #454
• Support inline catalog for validators #453
• Enforce inbound type checking; `kafk...

0.9.58

Changelog

0.9.58 (2023-11-13)

Full Changelog

Implemented enhancements:

• Integrate http binding with validators #455

Fixed bugs:

• [MQTT-Kafka] Exception runtime.binding.mqtt.kafka.internal.types.MqttExpirySignalFW.wrap(MqttExpirySignalFW.java:45) #563
• Running mqtt benchmark triggers mqtt exception #488
• Fix IndexOutOfBoundsException when receiving expiry signal #567 (bmaidics)

Merged pull requests:

• Integrate http binding with validators #571 (attilakreiner)
• Fix flow conrol bug + indexoutofbound exception #568 (bmaidics)

0.9.57 (2023-11-04)

Full Changelog

Fixed bugs:

• [Connection Pool] binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientConnection.doConnectionWindow(KafkaClientConnectionPool.java:1318) #565
• [MQTT-Kafka] Randomly closing the connection in the middle of produce triggers the exception #559
• Gracefully handle out of slot exception in kafka cache client produce #558
• [Connection Pool] Signaling can trigger exception #557
• http-kafka fetch binding returns malformed JSON when the payload is large #528

Merged pull requests:

• Ignore removing ack before receiving complete response even if the stream reply is closed #566 (akrambek)
• Fix bootstrap test #562 (bmaidics)
• Gracefully handle out of slot exception in kafka client produce #561 (akrambek)
• Better handling negative edge cases in the connection pool #560 (akrambek)
• Handle fragmentation in HttpFetchManyProxy #556 (akrambek)
• Added Contributors section in readme #553 (DhanushNehru)
• Fix: Added Contribution Section to Readme #550 (Kalyanimhala)

0.9.56 (2023-10-31)

Full Changelog

Implemented enhancements:

• Support extraEnv in helm chart #520
• kubernetes autoscaling feature (enhanced) #518
• Shard MQTT topic space for client-id specific subset #427
• Distribute MQTT topic space across different Kafka topics #426
• AsyncAPI integration (baseline) #257
• OpenAPI integration (baseline) #255
• mqtt-kafka feature (baseline) #190
• telemetry metrics feature (baseline) #188
• grpc-kafka feature (baseline) #183

Fixed bugs:

• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #551
• BudgetDebitor fails to claim budget after sometime #548
• Unexpected flush causes NPE in connection pool #546
• [Consumer Group] Race condition while joining simultaneously to the same group id #542
• MQTT client connections cause errors/crashes #527
• Sporadic github action build failures #526
• Unable to write to streams buffer under bidi-stream #368
• Fix flow control bug in mqtt-kakfa publish #524 (bmaidics)

Closed issues:

• Feature: Adding contributors section to the README.md file. #545
• gRPC method call doesn't respond when status code is not OK #504

Merged pull requests:

• Fix mqtt connect decoding bug when remainingLenght.size > 1 #554 (bmaidics)
• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #552 (akrambek)
• Don't send window before connection budgetId is assigned #549 (akrambek)
• Use coordinator member list to check if the heartbeat is allowed #547 (akrambek)
• Retry sync group request if there is inflight request #543 (akrambek)
• Add "Back to Top" in Readme.md #539 (PrajwalGraj)
• Create an appropriate buffer with the size that accommodates signal frame payload #537 (akrambek)
• Adjust padding for larger message header and don't include partial data while computing crc32c #536 (akrambek)
• Fix dump command to truncate output file if exists #534 (attilakreiner)
• fix typos in README.md #532 (shresthasurav)
• Fixed a typo in README.md #529 (saakshii12)
• Sporadic github action build failure fix #522 (akrambek)
• Propagate gRPC status code when not ok #519 (jfallows)
• Add extraEnv to Deployment in the helm chart #511 (attilakreiner)
• Client topic space #507 (bmaidics)
• Mqtt topic space #493 (bmaidics)

0.9.55 (2023-10-11)

Full Changelog

Implemented enhancements:

• Use 1-1 helm chart versioning strategy #487
• Generate mqtt server publish validators from AsyncAPI specification #461
• Integrate mqtt binding with validators #456
• Implement json validator #454
• Support inline catalog for validators #453
• Enforce inbound type checking; kafka cache produce client #312

Fixed bugs:

• 0 for no mqtt session expiry should be mapped to max value for the group stream #501
• Group stream with same group id may get hang #500
• Not cleaning up group stream on group leave response. #491
• Connection pool flowcontrol can trigger exception #482
• grpc server binding sends incorrect DATA flags for fragmented messages #397

Merged pull requests:

• 0 for no mqtt session expiry should be mapped to max integer value for the group stream #502 (akrambek)
• Better handle request with same group id #498 (akrambek)
• Remove stream on group leave response #492 (akrambek)
• Connection pool flowcontrol cleanup and minor bug fixes on group #490 (akrambek)
• update helm configs so appVersion is used as the tag #489 ([vordimous](https://gith...

0.9.57

Changelog

0.9.57 (2023-11-04)

Full Changelog

Fixed bugs:

• [Connection Pool] binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientConnection.doConnectionWindow(KafkaClientConnectionPool.java:1318) #565
• [MQTT-Kafka] Randomly closing the connection in the middle of produce triggers the exception #559
• Gracefully handle out of slot exception in kafka cache client produce #558
• [Connection Pool] Signaling can trigger exception #557
• http-kafka fetch binding returns malformed JSON when the payload is large #528

Merged pull requests:

• Ignore removing ack before receiving complete response even if the stream reply is closed #566 (akrambek)
• Fix bootstrap test #562 (bmaidics)
• Gracefully handle out of slot exception in kafka client produce #561 (akrambek)
• Better handling negative edge cases in the connection pool #560 (akrambek)
• Handle fragmentation in HttpFetchManyProxy #556 (akrambek)
• Added Contributors section in readme #553 (DhanushNehru)
• Fix: Added Contribution Section to Readme #550 (Kalyanimhala)

0.9.56 (2023-10-31)

Full Changelog

Implemented enhancements:

• Support extraEnv in helm chart #520
• kubernetes autoscaling feature (enhanced) #518
• Shard MQTT topic space for client-id specific subset #427
• Distribute MQTT topic space across different Kafka topics #426
• AsyncAPI integration (baseline) #257
• OpenAPI integration (baseline) #255
• mqtt-kafka feature (baseline) #190
• telemetry metrics feature (baseline) #188
• grpc-kafka feature (baseline) #183

Fixed bugs:

• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #551
• BudgetDebitor fails to claim budget after sometime #548
• Unexpected flush causes NPE in connection pool #546
• [Consumer Group] Race condition while joining simultaneously to the same group id #542
• MQTT client connections cause errors/crashes #527
• Sporadic github action build failures #526
• Unable to write to streams buffer under bidi-stream #368
• Fix flow control bug in mqtt-kakfa publish #524 (bmaidics)

Closed issues:

• Feature: Adding contributors section to the README.md file. #545
• gRPC method call doesn't respond when status code is not OK #504

Merged pull requests:

• Fix mqtt connect decoding bug when remainingLenght.size > 1 #554 (bmaidics)
• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #552 (akrambek)
• Don't send window before connection budgetId is assigned #549 (akrambek)
• Use coordinator member list to check if the heartbeat is allowed #547 (akrambek)
• Retry sync group request if there is inflight request #543 (akrambek)
• Add "Back to Top" in Readme.md #539 (PrajwalGraj)
• Create an appropriate buffer with the size that accommodates signal frame payload #537 (akrambek)
• Adjust padding for larger message header and don't include partial data while computing crc32c #536 (akrambek)
• Fix dump command to truncate output file if exists #534 (attilakreiner)
• fix typos in README.md #532 (shresthasurav)
• Fixed a typo in README.md #529 (saakshii12)
• Sporadic github action build failure fix #522 (akrambek)
• Propagate gRPC status code when not ok #519 (jfallows)
• Add extraEnv to Deployment in the helm chart #511 (attilakreiner)
• Client topic space #507 (bmaidics)
• Mqtt topic space #493 (bmaidics)

0.9.55 (2023-10-11)

Full Changelog

Implemented enhancements:

• Use 1-1 helm chart versioning strategy #487
• Generate mqtt server publish validators from AsyncAPI specification #461
• Integrate mqtt binding with validators #456
• Implement json validator #454
• Support inline catalog for validators #453
• Enforce inbound type checking; kafka cache produce client #312

Fixed bugs:

• 0 for no mqtt session expiry should be mapped to max value for the group stream #501
• Group stream with same group id may get hang #500
• Not cleaning up group stream on group leave response. #491
• Connection pool flowcontrol can trigger exception #482
• grpc server binding sends incorrect DATA flags for fragmented messages #397

Merged pull requests:

• 0 for no mqtt session expiry should be mapped to max integer value for the group stream #502 (akrambek)
• Better handle request with same group id #498 (akrambek)
• Remove stream on group leave response #492 (akrambek)
• Connection pool flowcontrol cleanup and minor bug fixes on group #490 (akrambek)
• update helm configs so appVersion is used as the tag #489 (vordimous)
• Bump org.apache.avro:avro from 1.11.2 to 1.11.3 #486 (dependabot[bot])
• Bump alpine from 3.18.3 to 3.18.4 in /cloud/docker-image/src/main/docker/release #484 (dependabot[bot])
• Fix publish timeout bug, increase default timeout #483 (bmaidics)
• Schema Config Update #481 (aDaemonThread)
• Feature/m1 docker build support #376 (vordimous)

0.9.54 (2023-09-26)

Full Changelog

Fixed bugs:

• Additional scenarios in connection pool cleanup can trigger exception [#475](https://github.com/aklivity/zilla/issu...

0.9.56

Changelog

0.9.56 (2023-10-31)

Full Changelog

Implemented enhancements:

• Support extraEnv in helm chart #520
• kubernetes autoscaling feature (enhanced) #518
• Shard MQTT topic space for client-id specific subset #427
• Distribute MQTT topic space across different Kafka topics #426
• AsyncAPI integration (baseline) #257
• OpenAPI integration (baseline) #255
• mqtt-kafka feature (baseline) #190
• telemetry metrics feature (baseline) #188
• grpc-kafka feature (baseline) #183

Fixed bugs:

• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #551
• BudgetDebitor fails to claim budget after sometime #548
• Unexpected flush causes NPE in connection pool #546
• [Consumer Group] Race condition while joining simultaneously to the same group id #542
• MQTT client connections cause errors/crashes #527
• Sporadic github action build failures #526
• Unable to write to streams buffer under bidi-stream #368
• Fix flow control bug in mqtt-kakfa publish #524 (bmaidics)

Closed issues:

• Feature: Adding contributors section to the README.md file. #545
• gRPC method call doesn't respond when status code is not OK #504

Merged pull requests:

• Fix mqtt connect decoding bug when remainingLenght.size > 1 #554 (bmaidics)
• Etag header field name MUST be converted to lowercase prior to their encoding in HTTP/2 #552 (akrambek)
• Don't send window before connection budgetId is assigned #549 (akrambek)
• Use coordinator member list to check if the heartbeat is allowed #547 (akrambek)
• Retry sync group request if there is inflight request #543 (akrambek)
• Add "Back to Top" in Readme.md #539 (PrajwalGraj)
• Create an appropriate buffer with the size that accommodates signal frame payload #537 (akrambek)
• Adjust padding for larger message header and don't include partial data while computing crc32c #536 (akrambek)
• Fix dump command to truncate output file if exists #534 (attilakreiner)
• fix typos in README.md #532 (shresthasurav)
• Fixed a typo in README.md #529 (saakshii12)
• Sporadic github action build failure fix #522 (akrambek)
• Propagate gRPC status code when not ok #519 (jfallows)
• Add extraEnv to Deployment in the helm chart #511 (attilakreiner)
• Client topic space #507 (bmaidics)
• Mqtt topic space #493 (bmaidics)

0.9.55 (2023-10-11)

Full Changelog

Implemented enhancements:

• Use 1-1 helm chart versioning strategy #487
• Generate mqtt server publish validators from AsyncAPI specification #461
• Integrate mqtt binding with validators #456
• Implement json validator #454
• Support inline catalog for validators #453
• Enforce inbound type checking; kafka cache produce client #312

Fixed bugs:

• 0 for no mqtt session expiry should be mapped to max value for the group stream #501
• Group stream with same group id may get hang #500
• Not cleaning up group stream on group leave response. #491
• Connection pool flowcontrol can trigger exception #482
• grpc server binding sends incorrect DATA flags for fragmented messages #397

Merged pull requests:

• 0 for no mqtt session expiry should be mapped to max integer value for the group stream #502 (akrambek)
• Better handle request with same group id #498 (akrambek)
• Remove stream on group leave response #492 (akrambek)
• Connection pool flowcontrol cleanup and minor bug fixes on group #490 (akrambek)
• update helm configs so appVersion is used as the tag #489 (vordimous)
• Bump org.apache.avro:avro from 1.11.2 to 1.11.3 #486 (dependabot[bot])
• Bump alpine from 3.18.3 to 3.18.4 in /cloud/docker-image/src/main/docker/release #484 (dependabot[bot])
• Fix publish timeout bug, increase default timeout #483 (bmaidics)
• Schema Config Update #481 (aDaemonThread)
• Feature/m1 docker build support #376 (vordimous)

0.9.54 (2023-09-26)

Full Changelog

Fixed bugs:

• Additional scenarios in connection pool cleanup can trigger exception #475

Merged pull requests:

• Integrate inline catalog and json validator with mqtt binding #479 (jfallows)
• Refactor config command #477 (jfallows)
• Remove streams only related to specific connection for additional scenarios #476 (akrambek)
• Cleanup log statements #474 (aDaemonThread)
• Json Validator and Inline Schema fix #473 (aDaemonThread)
• Http request validators feature flag #472 (jfallows)
• Avro validator module fix #470 (aDaemonThread)
• Include validators in the mqtt config generator #467 (attilakreiner)
• Json Validator #466 (aDaemonThread)
• Extract core validators #463 (attilakreiner)
• Mqtt validator implementation #452 (bmaidics)
• Cache support for Schema Registry #447 (aDaemonThread)
• Inline Catalog #445 (aDaemonThread)
• Extract avro validator #440 (attilakreiner)
• Introduce validators in th...

0.9.55

Changelog

0.9.55 (2023-10-11)

Full Changelog

Implemented enhancements:

• Use 1-1 helm chart versioning strategy #487
• Generate mqtt server publish validators from AsyncAPI specification #461
• Integrate mqtt binding with validators #456
• Implement json validator #454
• Support inline catalog for validators #453
• Enforce inbound type checking; kafka cache produce client #312

Fixed bugs:

• 0 for no mqtt session expiry should be mapped to max value for the group stream #501
• Group stream with same group id may get hang #500
• Not cleaning up group stream on group leave response. #491
• Connection pool flowcontrol can trigger exception #482
• grpc server binding sends incorrect DATA flags for fragmented messages #397

Merged pull requests:

• 0 for no mqtt session expiry should be mapped to max integer value for the group stream #502 (akrambek)
• Better handle request with same group id #498 (akrambek)
• Remove stream on group leave response #492 (akrambek)
• Connection pool flowcontrol cleanup and minor bug fixes on group #490 (akrambek)
• update helm configs so appVersion is used as the tag #489 (vordimous)
• Bump org.apache.avro:avro from 1.11.2 to 1.11.3 #486 (dependabot[bot])
• Bump alpine from 3.18.3 to 3.18.4 in /cloud/docker-image/src/main/docker/release #484 (dependabot[bot])
• Fix publish timeout bug, increase default timeout #483 (bmaidics)
• Schema Config Update #481 (aDaemonThread)
• Feature/m1 docker build support #376 (vordimous)

0.9.54 (2023-09-26)

Full Changelog

Fixed bugs:

• Additional scenarios in connection pool cleanup can trigger exception #475

Merged pull requests:

• Integrate inline catalog and json validator with mqtt binding #479 (jfallows)
• Refactor config command #477 (jfallows)
• Remove streams only related to specific connection for additional scenarios #476 (akrambek)
• Cleanup log statements #474 (aDaemonThread)
• Json Validator and Inline Schema fix #473 (aDaemonThread)
• Http request validators feature flag #472 (jfallows)
• Avro validator module fix #470 (aDaemonThread)
• Include validators in the mqtt config generator #467 (attilakreiner)
• Json Validator #466 (aDaemonThread)
• Extract core validators #463 (attilakreiner)
• Mqtt validator implementation #452 (bmaidics)
• Cache support for Schema Registry #447 (aDaemonThread)
• Inline Catalog #445 (aDaemonThread)
• Extract avro validator #440 (attilakreiner)
• Introduce validators in the http binding #435 (attilakreiner)
• Schema Registry and Kafka Produce Validator #434 (aDaemonThread)
• Move validators from binding-kafka to engine #415 (attilakreiner)
• Schema syntax validation for validator config #412 (attilakreiner)
• Schema registry docker build shaded #411 (jfallows)
• Schema registry Implementation #402 (aDaemonThread)
• UTF16 Validation implementation #401 (aDaemonThread)
• API abstraction for SchemaRegistry in Zilla #311 (aDaemonThread)

0.9.53 (2023-09-24)

Full Changelog

Fixed bugs:

• Connection cleanup can trigger exception #468

Merged pull requests:

• Release debitor on stream close and remove streams only related to specific connection #469 (akrambek)

0.9.52 (2023-09-23)

Full Changelog

Implemented enhancements:

• Connection pool for kafka binding heartbeat requests #462
• Enhance mqtt binding configuration syntax #420
• Mqtt-Kafka session implementation #319
• Design zilla.yaml configuration syntax for schema types #310
• Generate zilla.yaml from AsyncAPI specification #256
• Generate zilla.yaml from OpenAPI specification(s) #254
• Support kafka consumer groups #215
• MQTT guard implementation #307 (bmaidics)

Fixed bugs:

• Zilla crash during attempted WebSocket connection #391
• Index out of bounds exception with HTTP-Kafka proxy #293

Closed issues:

• Send will message as data frame + reject large packets #364
• Support Kafka client request-response with MQTT clients #326
• Add guard support for MQTT binding #308
• Implement retained feature for mqtt-kafka #289

Merged pull requests:

• Mqtt client publish fix #464 (bmaidics)
• Fix implicit subscribe no packetId reconnection #451 (bmaidics)
• Remove clientId from subscribeKey #450 (bmaidics)
• Rename config command to generate #449 (attilakreiner)
• Do not include generated subcsriptionId #448 (bmaidics)
• Adjust engine backoff strategy configuration #446 (jfallows)
• Don't close group stream on cluster and describe streams closer #444 (akrambek)
• Engine configuration worker capacity #443 (jfallows)
• Remove unused engine configuration #442 (jfallows)
• Ensure socket channel has finished connecting before attempting to read [#441](https://g...

0.9.54

Changelog

0.9.53 (2023-09-24)

Full Changelog

Fixed bugs:

• Connection cleanup can trigger exception #468

Merged pull requests:

• Release debitor on stream close and remove streams only related to specific connection #469 (akrambek)

0.9.52 (2023-09-23)

Full Changelog

Implemented enhancements:

• Connection pool for kafka binding heartbeat requests #462
• Enhance mqtt binding configuration syntax #420
• Mqtt-Kafka session implementation #319
• Design zilla.yaml configuration syntax for schema types #310
• Generate zilla.yaml from AsyncAPI specification #256
• Generate zilla.yaml from OpenAPI specification(s) #254
• Support kafka consumer groups #215
• MQTT guard implementation #307 (bmaidics)

Fixed bugs:

• Zilla crash during attempted WebSocket connection #391
• Index out of bounds exception with HTTP-Kafka proxy #293

Closed issues:

• Send will message as data frame + reject large packets #364
• Support Kafka client request-response with MQTT clients #326
• Add guard support for MQTT binding #308
• Implement retained feature for mqtt-kafka #289

Merged pull requests:

• Mqtt client publish fix #464 (bmaidics)
• Fix implicit subscribe no packetId reconnection #451 (bmaidics)
• Remove clientId from subscribeKey #450 (bmaidics)
• Rename config command to generate #449 (attilakreiner)
• Do not include generated subcsriptionId #448 (bmaidics)
• Adjust engine backoff strategy configuration #446 (jfallows)
• Don't close group stream on cluster and describe streams closer #444 (akrambek)
• Engine configuration worker capacity #443 (jfallows)
• Remove unused engine configuration #442 (jfallows)
• Ensure socket channel has finished connecting before attempting to read #441 (jfallows)
• Mqtt subscription handling bugfix #439 (bmaidics)
• Connection pool for kafka group client #438 (akrambek)
• Add affinity to mqtt server and client binding #436 (bmaidics)
• Set init flag for data fragmentation in grpc #431 (akrambek)
• Fix flow control issue in kafka-grpc #430 (akrambek)
• Fix known issues in group client #428 (akrambek)
• Enhance mqtt binding configuration syntax #425 (bmaidics)
• Buffer fragmented kafka session signal messages #424 (bmaidics)
• Fix flow control bug #423 (akrambek)
• Serverref change #422 (bmaidics)
• Fix finding next partition id #419 (akrambek)
• Don't end subscribe stream when unsubscribe, no subscription #418 (bmaidics)
• Remove default kafka topic names #416 (bmaidics)
• Fix consumer assignment causing decoding issue #414 (akrambek)
• Add test to validate merge produce rejection on wrong partition #410 (akrambek)
• Consumer related bug fixes #405 (akrambek)
• Remove unused extends OptionsConfig from non-options config classes #403 (jfallows)
• Support consumer protocol #400 (akrambek)
• Mqtt client implementation #398 (bmaidics)
• Support build after local docker zpm install #396 (jfallows)
• Adapt to consumer group changes #394 (bmaidics)
• Bump actions/checkout from 3 to 4 #393 (dependabot[bot])
• Merged consumer group support #390 (akrambek)
• Session expiry #387 (bmaidics)
• Request data length is non-negative #386 (jfallows)
• Fix mqtt-kafka publish bug #383 (bmaidics)
• Support configuration property definitions for custom type... #382 (jfallows)
• Mqtt kafka redirect #381 (bmaidics)
• Bump org.apache.ivy:ivy from 2.5.1 to 2.5.2 in /manager #377 (dependabot[bot])
• Generate zilla.yaml for asyncapi.mqtt.proxy from an AsyncAPI definition #375 (attilakreiner)
• Review budget debitors #374 (jfallows)
• Support binding config builder exit #373 (jfallows)
• Support config builder for MQTT config #372 (jfallows)
• Bump org.codehaus.mojo:exec-maven-plugin from 1.6.0 to 3.1.0 #370 (dependabot[bot])
• Generate zilla.yaml from an AsyncAPI definition #369 (attilakreiner)
• Mqtt kafka will message delivery #367 (bmaidics)
• Bump org.apache.maven.plugins:maven-plugin-plugin from 3.5 to 3.9.0 #366 (dependabot[bot])
• Bump junit:junit from 4.13.1 to 4.13.2 #365 (dependabot[bot])
• Send will message as data frame + reject large packets #363 (bmaidics)
• Sanitize zip entry path #362 (jfallows)
• Bump org.apache.maven:maven-core from 3.6.0 to 3.8.1 #361 (dependabot[bot])
• Merge consumer group metadata #359 (akrambek)
• Support dynamic behavior injection in config builder fluent API #358 (jfallows)
• Bump org.apache.maven.plugins:maven-jar-plugin from 3.2.0 to 3.3.0 #357 (dependabot[bot])
• Bump com.squareup:javapoet from 1.9.0 to 1.13.0 #355 ([dependabot[bot]](https:/...

0.9.53

Changelog

0.9.53 (2023-09-24)

Full Changelog

Fixed bugs:

• Connection cleanup can trigger exception #468

Merged pull requests:

• Release debitor on stream close and remove streams only related to specific connection #469 (akrambek)

0.9.52 (2023-09-23)

Full Changelog

Implemented enhancements:

• Connection pool for kafka binding heartbeat requests #462
• Enhance mqtt binding configuration syntax #420
• Mqtt-Kafka session implementation #319
• Design zilla.yaml configuration syntax for schema types #310
• Generate zilla.yaml from AsyncAPI specification #256
• Generate zilla.yaml from OpenAPI specification(s) #254
• Support kafka consumer groups #215
• MQTT guard implementation #307 (bmaidics)

Fixed bugs:

• Zilla crash during attempted WebSocket connection #391
• Index out of bounds exception with HTTP-Kafka proxy #293

Closed issues:

• Send will message as data frame + reject large packets #364
• Support Kafka client request-response with MQTT clients #326
• Add guard support for MQTT binding #308
• Implement retained feature for mqtt-kafka #289

Merged pull requests:

• Mqtt client publish fix #464 (bmaidics)
• Fix implicit subscribe no packetId reconnection #451 (bmaidics)
• Remove clientId from subscribeKey #450 (bmaidics)
• Rename config command to generate #449 (attilakreiner)
• Do not include generated subcsriptionId #448 (bmaidics)
• Adjust engine backoff strategy configuration #446 (jfallows)
• Don't close group stream on cluster and describe streams closer #444 (akrambek)
• Engine configuration worker capacity #443 (jfallows)
• Remove unused engine configuration #442 (jfallows)
• Ensure socket channel has finished connecting before attempting to read #441 (jfallows)
• Mqtt subscription handling bugfix #439 (bmaidics)
• Connection pool for kafka group client #438 (akrambek)
• Add affinity to mqtt server and client binding #436 (bmaidics)
• Set init flag for data fragmentation in grpc #431 (akrambek)
• Fix flow control issue in kafka-grpc #430 (akrambek)
• Fix known issues in group client #428 (akrambek)
• Enhance mqtt binding configuration syntax #425 (bmaidics)
• Buffer fragmented kafka session signal messages #424 (bmaidics)
• Fix flow control bug #423 (akrambek)
• Serverref change #422 (bmaidics)
• Fix finding next partition id #419 (akrambek)
• Don't end subscribe stream when unsubscribe, no subscription #418 (bmaidics)
• Remove default kafka topic names #416 (bmaidics)
• Fix consumer assignment causing decoding issue #414 (akrambek)
• Add test to validate merge produce rejection on wrong partition #410 (akrambek)
• Consumer related bug fixes #405 (akrambek)
• Remove unused extends OptionsConfig from non-options config classes #403 (jfallows)
• Support consumer protocol #400 (akrambek)
• Mqtt client implementation #398 (bmaidics)
• Support build after local docker zpm install #396 (jfallows)
• Adapt to consumer group changes #394 (bmaidics)
• Bump actions/checkout from 3 to 4 #393 (dependabot[bot])
• Merged consumer group support #390 (akrambek)
• Session expiry #387 (bmaidics)
• Request data length is non-negative #386 (jfallows)
• Fix mqtt-kafka publish bug #383 (bmaidics)
• Support configuration property definitions for custom type... #382 (jfallows)
• Mqtt kafka redirect #381 (bmaidics)
• Bump org.apache.ivy:ivy from 2.5.1 to 2.5.2 in /manager #377 (dependabot[bot])
• Generate zilla.yaml for asyncapi.mqtt.proxy from an AsyncAPI definition #375 (attilakreiner)
• Review budget debitors #374 (jfallows)
• Support binding config builder exit #373 (jfallows)
• Support config builder for MQTT config #372 (jfallows)
• Bump org.codehaus.mojo:exec-maven-plugin from 1.6.0 to 3.1.0 #370 (dependabot[bot])
• Generate zilla.yaml from an AsyncAPI definition #369 (attilakreiner)
• Mqtt kafka will message delivery #367 (bmaidics)
• Bump org.apache.maven.plugins:maven-plugin-plugin from 3.5 to 3.9.0 #366 (dependabot[bot])
• Bump junit:junit from 4.13.1 to 4.13.2 #365 (dependabot[bot])
• Send will message as data frame + reject large packets #363 (bmaidics)
• Sanitize zip entry path #362 (jfallows)
• Bump org.apache.maven:maven-core from 3.6.0 to 3.8.1 #361 (dependabot[bot])
• Merge consumer group metadata #359 (akrambek)
• Support dynamic behavior injection in config builder fluent API #358 (jfallows)
• Bump org.apache.maven.plugins:maven-jar-plugin from 3.2.0 to 3.3.0 #357 (dependabot[bot])
• Bump com.squareup:javapoet from 1.9.0 to 1.13.0 #355 ([dependabot[bot]](https:/...