Skip to content

0.9.100

Latest
Latest
Compare
Choose a tag to compare
@jfallows jfallows released this 30 Oct 20:10
· 4 commits to develop since this release
0.9.100
354b780

Changelog

0.9.100 (2024-10-29)

Full Changelog

Implemented enhancements:

  • Replace jsqlparser with antlr grammar #1301
  • Support pgsql-kafka binding #1058
  • syntax check mqtt topic names and topic filters in zilla.yaml #521

Fixed bugs:

  • Zilla asyncapi.mqtt.kafka.proxy crash on startup with NPE: Cannot read field "values" because the return value of "...AsyncapiServerVariableResolver.resolve(String)" is null #1304
  • Using the Zilla MQTT broker the producer periodically disconnect and only reconnects after pod restart #1302
  • SSE notifications stop after about 5-6 times when using kafka-sse #1291
  • POST application/protobuf binary data can get stuck #1283
  • JSON to Protobuf breaks after processing an invalid message #1282
  • Zilla intermittently crashes with IndexOutOfBoundsException at high mqtt load #1206
  • Load testing MQTT QOS 0,1,2 with Empty messages in the retained topic and Zilla crashing #1164

Closed issues:

  • pgsql DROP TOPIC command to KafkaDeleteTopicsBeginEx #1307
  • Log missing enviroment variables. #1188

Merged pull requests:

0.9.99 (2024-10-12)

Full Changelog

Merged pull requests:

0.9.98 (2024-10-10)

Full Changelog

Fixed bugs:

  • Propagate error code in risingwave binding that's coming either from pgsql-kafka or risingwave #1286
  • Zilla get blocked when sending messages to kafka #1268

Merged pull requests:

  • Propagate error code in risingwave binding that's coming either from pgsql-kafka or risingwave #1288 (akrambek)
  • Increase write buffer size to accomidate longer path #1287 (akrambek)

0.9.97 (2024-10-07)

Full Changelog

Implemented enhancements:

  • Support jwt guarded identity via custom token claim #1276
  • Support insert into to seed kafka messages via risingwave binding #1274

Merged pull requests:

  • pgsql DROP TOPIC command to KafkaDeleteTopicsBeginEx plus catalog unregister subject #1280 (akrambek)
  • external udf - python support #1278 (ankitk-me)
  • Support jwt guarded identity via custom token claim #1277 (akrambek)
  • Support insert into to seed kafka messages via risingwave binding #1275 (akrambek)

0.9.96 (2024-10-01)

Full Changelog

Implemented enhancements:

  • Support Kafka topics create, alter, delete #1059

Fixed bugs:

  • zilla Fails to Load Configuration from Specified location if the initial attempts are unsuccessful #1226

Merged pull requests:

0.9.95 (2024-09-23)

Full Changelog

Fixed bugs:

  • NPE durring high load: Cannot invoke "io.aklivity.zilla.runtime.binding.kafka.internal.types.KafkaEvaluation.ordinal()" because "evaluation" is null #1253

Merged pull requests:

0.9.94 (2024-09-21)

Full Changelog

Implemented enhancements:

  • Add more events to Zilla's connection with Kafka or other tcp clients #1123
  • Ignore case when evaluating enums #1109
  • Support catalog register new schema version #1060

Fixed bugs:

  • Zilla KafkaGroup stream stuck on decoding FindCoordinatorResponse #1201
  • NPE when a schema isn't found in a schema registry #1170
  • Fetching from a log compacted topic pulls all new messages with same key on first call #803

Merged pull requests:

0.9.93 (2024-09-10)

Full Changelog

Implemented enhancements:

  • Support pgsql binding #1057
  • Handle large HTTP headers #1046
  • Gracefully handle zilla.yml instead of zilla.yaml #580

Fixed bugs:

  • Zilla OpenAPI not supporting filesystem catalog #1225
  • Zilla produces corrupt messages due to incorrect CRC when fragmented #1221
  • Issue referencing guard in asyncapi binding #1215
  • Using catalog::apicurio triggers unexpected behaviour #1202
  • 400 Bad Request response from Zilla when Using Java HttpClient #1192
  • Investigate connection pool reconnect when Kafka not yet available #1153

Merged pull requests:

0.9.92 (2024-08-13)

Full Changelog

Implemented enhancements:

  • Support extract-key kafka message transform #1176

Merged pull requests:

0.9.91 (2024-08-10)

Full Changelog

Fixed bugs:

  • asyncapi binding triggers zilla crash when used with catalog::apicurio #1185
  • Avro to JSON conversion problem with REST Proxy #1169

Merged pull requests:

  • Support SKIP_MANY only kafka headers sequence filter #1189 (jfallows)
  • Enables bindings:asyncapi to use catalog::apicurio #1186 (ankitk-me)

0.9.90 (2024-08-05)

Full Changelog

Implemented enhancements:

  • Support extract-headers kafka message transform #1175
  • Simplify sse support in AsyncAPI specs #1151

Fixed bugs:

  • Support topic pattern wildcards in mqtt-kafka clients #1178
  • Connecting to Aiven Kafka over TLS Throws an java.security.InvalidAlgorithmParameterException: the trustAnchors parameter must be non-empty Error #1115

Merged pull requests:

  • Resolve server binding protocol type dissector … #1181 (jfallows)
  • Apply minimum mqtt timeout constraint … #1180 (jfallows)
  • Update MQTT wildcard processing for client topic patterns #1179 (jfallows)
  • Support extract-headers kafka message transform #1177 (akrambek)
  • Refactor asyncapi binding to simplify SSE asyncapi bindings extension #1171 (jfallows)
  • Add validation for invalid path in http-kafka #1168 (bmaidics)
  • Bump alpine from 3.20.1 to 3.20.2 in /cloud/docker-image/src/main/docker #1165 (dependabot[bot])
  • tls binding require vault and keys or signers in options #1159 (ankitk-me)

0.9.89 (2024-07-22)

Full Changelog

Implemented enhancements:

  • Support asyncapi mapping sse protocol to kafka protocol #1064
  • Helm chart option for handling HTTP/2 behind an Ingress controller #896
  • Support grpc custom metadata pass through #730
  • Export telemetry logs to local filesystem #298
  • Integrate OpenTelemetry collectors by exporting local log events over OTLP #297
  • Design observable logs configuration syntax #296
  • telemetry logs feature #295

Fixed bugs:

  • custom metadata populated by grpc-server missing #1155
  • Avro validation returns 204 and produces blank message #1143
  • Fix WS large message bug #725 (bmaidics)

Merged pull requests:

0.9.88 (2024-07-15)

Full Changelog

Implemented enhancements:

  • AsyncAPI http-kafka header overrides support #1141

Fixed bugs:

  • AsyncAPI sse kafka filtering support #1137

Merged pull requests:

  • Support asyncapi authorization in http kafka and sse kafka #1150 (akrambek)
  • MInor fixes for asyncapi sse-kafka and http-kafka binding support #1149 (akrambek)
  • Support sse-kafka header filters from AsyncAPI sse operation #1148 (jfallows)
  • Support http-kafka header overrides from AsyncAPI http operation #1147 (jfallows)
  • fix: update readme links #1146 (vordimous)
  • Support http authorization in asyncapi generation #1145 (akrambek)
  • update ingress values and implementation #1142 (vordimous)

0.9.87 (2024-07-12)

Full Changelog

Merged pull requests:

  • Support multiple requests with single window ack on shared connection #1144 (jfallows)

0.9.86 (2024-07-10)

Full Changelog

Merged pull requests:

  • Handle incremental key validation when length increases #1140 (akrambek)

0.9.85 (2024-07-10)

Full Changelog

Implemented enhancements:

  • add option to print version information to the cli tools #1066

Fixed bugs:

  • Support key validation in kafka asyncapi generation #1105
  • Asyncapi doesn't generate schema for catalog with avro format #1104

Closed issues:

  • Add more context to the Kafka API event code log formatter. #1126

Merged pull requests:

0.9.84 (2024-06-29)

Full Changelog

Implemented enhancements:

  • Verify public-private key pair obtained from vault used for TLS handshake #1073

Closed issues:

  • feat: improve troubleshooting capabilities #903

Merged pull requests:

0.9.83 (2024-06-28)

Full Changelog

Implemented enhancements:

  • Add asyncapi http-kafka proxy example #1077
  • Use miliseconds in metrics #1069
  • Promote filesystem catalog out of incubator #1068
  • Support asyncapi mapping http protocol to kafka protocol #1063
  • Support filtering by kafka structured value field(s) #1062
  • Support remote zilla configuration with change detection #1061
  • Use full Event ID and the event name #1013
  • Support configuration of MQTT Publish QoS maximum #970
  • Support sse server and client via asyncapi #952
  • Review kafka binding partition offset vs progress offset #285

Fixed bugs:

  • iNotify error when multiple Zilla instances are started in K8s Pods on a Portainer.io host #1081
  • Running emqtt_bench sub triggers an exception #1037
  • MqttSessionBeginEx missing packetIds in zilla dump #1028
  • Running emqtt_bench triggers an exception in mqtt during the decoding #999
  • Intermittent NPE when trying to resolve guards #994

Closed issues:

  • Add SSE payload validation to sse-server binding #1076

Merged pull requests:

0.9.82 (2024-05-28)

Full Changelog

Fixed bugs:

  • Zilla crashes with IllegalArgumentException: cannot accept missingValue when using defaultOffset: live #1051
  • Zilla crashes on mqtt cli -T option #1039
  • Running emqtt_bench both sub and pub triggers an exception #1000
  • http-kafka will fetch messages that have been deleted by a retention policy #897

Merged pull requests:

  • Update to handle catalog IT validation(resolve schema from subject) #1055 (ankitk-me)
  • Queue as different kafka produce request if producerId or producerEpoch varies #1053 (akrambek)
  • Support kafka cache bootstrap with topic default offset live #1052 (jfallows)
  • Set decoder to ignoreAll after session is taken over by other MQTT client #1045 (bmaidics)
  • Add detection of non-compacted session topic #1044 (bmaidics)
  • Fix: http-kafka will fetch messages that have been deleted by a reten… #1033 (ankitk-me)

0.9.81 (2024-05-24)

Full Changelog

Implemented enhancements:

  • Improve Starting Zilla with the CLI #1016
  • Generate zilla dump packet captures in timestamp order including across workers #959
  • Split protocol testing into separate ITs for zilla dump command #958
  • Add zilla context to MQTT consumer groups #886

Fixed bugs:

  • Telemetry attribute service.name doesn't get sent correctly #1007
  • Streampay zilla instance crashes while trying to access https://localhost:9090 #975

Merged pull requests:

0.9.80 (2024-05-20)

Full Changelog

Breaking changes:

  • Remove zilla generate command #960
  • Report unused properties based on binding definition #808

Implemented enhancements:

  • Update the Zilla issue Bug Report template with debugging info collection instructions #991
  • Support multiple specs in openapi-asyncapi binding #964
  • Integrate JMH into tls binding #961
  • Enhance validation for openapi and asyncapi bindings #950
  • Support multiple specs in openapi binding #949
  • Support multiple specs in asyncapi binding #948
  • Support asyncapi mqtt streetlights mapping to kafka streetlights #947
  • Support mqtt access log #945
  • Support mqtt client binding authorization #940
  • Resiliently handle apicurio catalog unreachable #938
  • Resiliently handle karapace catalog unreachable #937
  • Support local zilla installation on MacOS via homebrew #680
  • Update bug report template #820 (vordimous)

Fixed bugs:

  • Zilla crashes with IllegalArgumentException when an Avro payload is fetched as json #1025
  • MQTT-Kafka qos2: increasing tracked producer sequence number without publishing to Kafka #1014
  • OTLP logs signal doesn't show up in OpenTelemetry Demo #1006
  • Flow control issue in openapi binding #1004
  • mqtt connecting with longer client id fails #1003
  • Running zilla with the kafka-grpc binding in a cluster with multiple instances results in each instance delivering a message to the configured remote_server #882
  • Using the grpc.kafka.proxy example setup, Zilla will periodically not deliver the message to the gRPC service defined in the kafka-grpc binding #881
  • Flaky kafka-grpc test #768

Merged pull requests:

0.9.79 (2024-04-22)

Full Changelog

Implemented enhancements:

  • Support filesystem catalog for local schemas #908
  • Check for files on startup when the zilla.yaml specifies paths to files or directories #292

Fixed bugs:

  • Fix k3po does not reload labels when labels file size decreases #972 (bmaidics)

Merged pull requests:

0.9.78 (2024-04-16)

Full Changelog

Merged pull requests:

  • Ensure binding types are populated for zilla dump to dissect protocol-specific frames #928 (attilakreiner)

0.9.77 (2024-04-15)

Full Changelog

Merged pull requests:

  • zilla dump : bindings not found in /var/runtime/zilla directory #927 (ankitk-me)
  • README Docs links and formatting fixes #926 (vordimous)

0.9.76 (2024-04-15)

Full Changelog

Merged pull requests:

0.9.75 (2024-04-12)

Full Changelog

Implemented enhancements:

  • Support logging of events caused by Model #887
  • Helm chart QoL improvements #884
  • Support mqtt streetlights AsyncAPI validating proxy #880
  • Promote components out of incubator #879
  • Support specific server in AsyncAPI spec in asyncapi binding #878
  • Support specific server in OpenAPI spec in openapi binding #877
  • Support HTTP prefer async with OpenAPI #876
  • Support OpenAPI and AsyncAPI validation cases #814
  • Integrate openapi and asyncapi with catalog #813

Fixed bugs:

  • Error in JsonValidatorHandler when the remote registry can't be accessed #817
  • Zilla doesn't communicate with bitnami/kafka in Taxi demo #690
  • Bootstrap options on cache_client vs cache_server for the kafka binding #388

Merged pull requests:

0.9.74 (2024-03-19)

Full Changelog

Merged pull requests:

0.9.73 (2024-03-18)

Full Changelog

Merged pull requests:

0.9.72 (2024-03-17)

Full Changelog

Merged pull requests:

0.9.71 (2024-03-15)

Full Changelog

Implemented enhancements:

  • Support apicurio as catalog for specifications #812
  • Support remote logging of events via otlp #785

Fixed bugs:

  • Openapi and asyncapi parsers throw a null pointer when a none 0 patch version is used. #841
  • mosquitto_pub qos 0 fails validation with a valid message #838
  • Zilla Quickstart gRPC RouteGuide service hangs after lots of messages #719

Merged pull requests:

  • Add key filter support in openapi asyncapi mapping #851 (akrambek)
  • Support verbose output of internally generated composite namespaces #850 (jfallows)
  • Use correct offset when response has no record set #849 (akrambek)
  • Fix binding metadata for composite bindings #847 (attilakreiner)
  • CacheProduceIT.shouldRejectMessageValues nondeterministic failure fix #845 (ankitk-me)
  • Implement JoinGroup request as first class stream #844 (akrambek)
  • Fix patch detection in openapi and asyncapi #843 (akrambek)
  • Fix mosquitto_pub fails validation with a valid message #840 (bmaidics)
  • Add event logs to open telemetry exporter #839 (attilakreiner)
  • Add Apicurio catalog #827 (bmaidics)

0.9.70 (2024-03-07)

Full Changelog

Fixed bugs:

  • Using parameter expansion in bash doesn't work in the docker containers. #829
  • Zilla crashes when a lot of MQTT clients are connected #762

Merged pull requests:

0.9.69 (2024-03-04)

Full Changelog

Implemented enhancements:

  • Use dedicated env var to enable Incubator features #800
  • Support http to kafka proxy using openapi.yaml and asyncapi.yaml #742
  • Support mqtt to kafka proxy using asyncapi.yaml #741
  • Support openapi http proxy using openapi.yaml #740
  • Support asyncapi http proxy using asyncapi.yaml #739
  • Support asyncapi mqtt proxy using asyncapi.yaml #738
  • Support local logging of events caused by external actors #679
  • Support parameters in KafkaTopicsConfig #809 (bmaidics)

Fixed bugs:

  • SEVERE: Problem adapting object of type class NamespaceConfig to interface jakarta.json.JsonObject in class class NamespaceAdapter #796
  • Zilla is validating env vars before replacing them. #795
  • Basic Docker Compose Setup Clogs CPU With Error Messages #722

Merged pull requests:

0.9.68 (2024-02-13)

Full Changelog

Fixed bugs:

  • Zilla crashes when a large number of MQTT clients connect #793

Merged pull requests:

  • Require group host and port for kafka coordinator-specific streams #794 (jfallows)

0.9.67 (2024-02-11)

Full Changelog

Implemented enhancements:

  • Use model and view when describing the message type #750
  • Support obtaining protobuf schemas from schema registry for grpc services #697
  • Support idempotent mqtt qos 2 publish to kafka #677
  • Detect and inspect invalid messages received #676
  • Support incremental validation of fragmented messages sent by client #671
  • Catalog cache TTL implementation #658 (ankitk-me)

Fixed bugs:

  • TLSv1.3 client handshake stall #791
  • Zilla crashes when it tries to send flush on retain stream #770
  • Running emqtt_bench triggers exception in connection pool #716
  • mqtt-kafka does not limit client sharding to mqtt v5 #708
  • tls binding should handle null key returned from vault #395
  • Fix zilla crash when it tries to send flush on retain stream #784 (bmaidics)
  • Limit sharding to mqtt 5 #760 (bmaidics)

Merged pull requests:

0.9.66 (2024-01-24)

Full Changelog

Implemented enhancements:

  • Support openapi http response validation #684
  • Support protobuf conversion to and from json for kafka messages #682
  • Support incubator features preview in zilla release docker image #670

Fixed bugs:

  • Schema validation fails before the ${{env.*}} parameters have been removed #583

Merged pull requests:

  • update license exclude path to include both zpmw files #759 (vordimous)
  • Refactor resolvers to support configuration #758 (jfallows)
  • Fix docker file path #756 (akrambek)
  • Support incubator features preview in zilla release docker image #753 (akrambek)
  • Support expression for primitive type in json schema #751 (akrambek)
  • Implement response validation in http client binding #732 (attilakreiner)

0.9.65 (2024-01-18)

Full Changelog

Implemented enhancements:

  • Support avro conversion to and from json for kafka messages #681
  • Support observability of zilla engine internal streams #678
  • Simplify configuration of multiple protocols on different tcp ports #669
  • Simplify kafka client bootstrap server names and ports config #619
  • MQTT publish QoS 2 as Kafka produce with acks in_sync_replicas and idempotent producerId #605
  • Add the option to route by port in the tls binding #564
  • Support outbound message transformation from protobuf to json #458
  • Support inbound message transformation from json to protobuf #457
  • Support outbound message transformation from avro to json #315
  • Support inbound message transformation from json to avro #313
  • Handle data fragmentation for MQTT binding #282
  • separating publish streams based on qos #726 (bmaidics)
  • Add sse, ws, fs extension parsing to dump command #660 (attilakreiner)
  • Support MQTT fragmented messages #651 (bmaidics)

Fixed bugs:

  • Unable to Run MQTT Example Successfully #724
  • Http1 server not progressing after reaching full buffer slot size #715
  • mqtt-kafka binding uses 2 different consumer groups per mqtt client #698
  • Optimize memory allocation for mqtt-kafka offset tracking #675
  • connection pool stops handling signals after while causing mqtt client to hang #667
  • Kafka Merge is getting stall because of intermediate partition offset state #666
  • Handle large message in grpc binding #648
  • update zilla jsonschemas #637
  • Mqtt session takeover is not working when the second client connects to the same Zilla instance #620
  • http2.network.ConnectionManagementIT.serverSent100kMessage test fails sporadically due to race #134
  • Fix tcp flow control issue #704 (bmaidics)
  • Optimize memory allocation for mqtt-kafka offset tracking #694 (bmaidics)
  • Send disconnect even without mqtt reset extension #689 (bmaidics)

Closed issues:

  • Prototype composite binding support with nested namespaces #685
  • Build has been failed in local #229

Merged pull requests:

0.9.64 (2023-12-25)

Full Changelog

Merged pull requests:

0.9.63 (2023-12-25)

Full Changelog

Implemented enhancements:

Fixed bugs:

  • OffsetFetch Request should connect to the coordinator instead of a random member of cluster #653
  • Mqtt-kakfa will message bugfixes #644 (bmaidics)

Closed issues:

  • gRPC remote_server gets duplicate messages #480
  • Log compaction behavior with or without bootstrap is not consistent #389

Merged pull requests:

  • Fix static field #655 (akrambek)
  • OffsetFetch Request should connect to the coordinator instead of a random member of cluster #654 (akrambek)
  • Bump actions/upload-artifact from 3 to 4 #645 (dependabot[bot])
  • Bump github/codeql-action from 2 to 3 #643 (dependabot[bot])
  • Fix java.util.MissingFormatArgumentException when using Kafka debugging. #639 (voutilad)
  • Json schema errors #638 (vordimous)
  • Add jumbograms and proxy extension parsing to dump command #635 (attilakreiner)
  • Bump ubuntu from jammy-20230916 to jammy-20231128 in /cloud/docker-image/src/main/docker/incubator #608 (dependabot[bot])
  • Bump ubuntu from jammy-20230916 to jammy-20231128 in /cloud/docker-image/src/main/docker/release #607 (dependabot[bot])

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:

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:

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:

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 (ankitk-me)
  • 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:

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)
Assets 2
Loading