Skip to content

Latest commit

 

History

History
2136 lines (1497 loc) · 162 KB

CHANGELOG.md

File metadata and controls

2136 lines (1497 loc) · 162 KB
Raw

Changelog

0.9.101 (2024-11-07)

Full Changelog

Fixed bugs:

  • Running emqtt_bench triggers exception in KafkaCacheCursorFactory #752

Closed issues:

  • Support ALTER STREAM and ALTER TABLE transformation #1319

Merged pull requests:

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)

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:

0.9.51 (2023-07-27)

Full Changelog

Implemented enhancements:

  • Enhance tcp binding to route by port #294
  • Integrate OpenTelemetry collectors by exporting local metrics over OTLP #112

Closed issues:

  • Add redirect, server reference support to mqtt binding #302
  • Add options to mqtt-kafa binding so we can change kafka topics #300

Merged pull requests:

0.9.50 (2023-07-14)

Full Changelog

Implemented enhancements:

  • kubernetes autoscaling feature (baseline) #189

Closed issues:

  • Update image base #291

Merged pull requests:

  • update Helm logo & details and clean up README #273 (vordimous)

0.9.49 (2023-06-28)

Full Changelog

Implemented enhancements:

  • Kafka merged flush should support filter changes #259

Closed issues:

  • Null pointer when Headers are null #281

Merged pull requests:

  • Remove unnecessary cursor assignment #288 (akrambek)
  • Eliminate zilla.json warning if file not present #286 (jfallows)
  • Send kafka flush even if data frames were sent to notify client from HISTORICAL to LIVE transition #284 (bmaidics)
  • KafkaMerged acknowledge flush frame #258 (bmaidics)

0.9.48 (2023-06-23)

Full Changelog

Implemented enhancements:

  • Support additional grpc specific metrics #233

Fixed bugs:

  • CacheMergedIT.shouldFetchMergedMessagesWithIsolationReadCommitted fails only on GitHub Actions #239
  • CacheFetchIT.shouldReceiveMessagesWithIsolationReadUncommittedWhenAborting fails only on GitHub Actions #236

Merged pull requests:

0.9.47 (2023-05-14)

Full Changelog

Merged pull requests:

0.9.46 (2023-05-14)

Full Changelog

0.9.45 (2023-05-14)

Full Changelog

Implemented enhancements:

  • Generic helm chart #242

Merged pull requests:

0.9.44 (2023-05-13)

Full Changelog

Implemented enhancements:

  • Simplify zilla.yaml errors on invalid input #222
  • MQTT and MQTT-Kafka bindings #196
  • Support additional http specific metrics #111

Closed issues:

  • Refactor existing MQTT specs #179

Merged pull requests:

0.9.43 (2023-05-10)

Full Changelog

Implemented enhancements:

  • Enhance grpc related binding configuration #226
  • Move kafka-grpc options for grpc to with section of config #218
  • Remove zilla load now that we have zilla metrics instead #214
  • Minimize on-stack performance overhead of metrics recording #213
  • Support eager evaluation of all kafka filters and indicate which filters matched #209
  • Integrate Prometheus by exporting local metrics over HTTP #193
  • Support gRPC Kafka server streaming #186
  • Support Kafka gRPC mapping #185
  • Support gRPC Kafka mapping #184
  • Enhance kafka binding to notify transition from historical to live messages #172
  • Support gRPC proxying #171
  • Convert zilla spec config .json files to .yaml extension and syntax #164
  • When starting up in verbose mode make sure there is a newline after printing the config #157
  • Support dynamic zilla configuration via https #139
  • Watch zilla configuration for changes and apply automatically #138
  • Enhance idempotency support for HTTP-Kafka binding #113
  • Provide zilla metrics command to report current values locally #110
  • Migrate implicit stream open, close, error, bytes metrics to explicit configuration syntax #109
  • Design observable metrics configuration syntax #100
  • Enhance http client binding to support h2 protocol #99
  • Simplify configuration for JWT identity provider signing keys #68
  • Refactor core.idl with originId and routedId #195 (jfallows)

Fixed bugs:

  • During reconfigure, we don't log errors #177
  • Flyweight wrapping error race condition #146
  • CacheMergedIT.shouldFetchMergedMessageValues fails only on GitHub Actions #131
  • Add log + rollback on reconfigure errors #178 (bmaidics)

Closed issues:

  • Migrate zilla README from zilla.json to zilla.yaml #159

Merged pull requests:

0.9.42 (2023-01-29)

Full Changelog

Implemented enhancements:

  • Support YAML syntax for Zilla configuration #144

Merged pull requests:

0.9.41 (2023-01-27)

Full Changelog

Merged pull requests:

0.9.40 (2023-01-25)

Full Changelog

Implemented enhancements:

  • Support {{ mustache }} syntax in zilla.json #91

Merged pull requests:

0.9.39 (2023-01-23)

Full Changelog

0.9.38 (2023-01-23)

Full Changelog

0.9.37 (2023-01-23)

Full Changelog

Implemented enhancements:

  • Follow standard layout for zilla files in docker image #140

Fixed bugs:

  • NPE when reloading browser page, mid produce #151

Merged pull requests:

0.9.35 (2023-01-19)

Full Changelog

Fixed bugs:

  • kafka cache treats non-compacted topics as compacted #147

Merged pull requests:

  • Resolve stall for large files served over HTTP/2 #149 (jfallows)
  • Skip ancestor messages for compacted topic configuration only #148 (jfallows)

0.9.34 (2023-01-16)

Full Changelog

Implemented enhancements:

  • Support guarded identities in http-kafka and sse-kafka #145 (jfallows)

Merged pull requests:

0.9.33 (2022-12-14)

Full Changelog

Merged pull requests:

0.9.32 (2022-11-28)

Full Changelog

Implemented enhancements:

  • Implement zilla dump command similar to tcpdump #114

Merged pull requests:

0.9.31 (2022-11-17)

Full Changelog

Implemented enhancements:

  • Remove merged from kafka binding configuration #108
  • Simplify duplicate request detection at event-driven microservices #71

Fixed bugs:

  • Error running http.kafka.oneway from zilla-examples #117
  • Zilla build fails on timeout #102

Merged pull requests:

  • Fix uint32 as array length #128 (akrambek)
  • Adjust expectations to handle the case where we extend window max … #125 (jfallows)
  • Remove merged from kafka binding configuration #122 (ankitk-me)
  • Fix NPE caused by no KafkaMergedDataEx present on the DATA frame... #120 (attilakreiner)
  • Mark flyweight plugin goals @threadSafe #119 (jfallows)
  • Upgrade ANTLR version #118 (jfallows)
  • Replace HttpRequest with buffer slot #105 (akrambek)
  • Increase frame count for byteman to find matching call stack method #104 (jfallows)
  • Document how to run the benchmark with Java 16+ #103 (antonmry)
  • BugFix: process configURL if the protocol is http #101 (Alfusainey)

0.9.30 (2022-09-19)

Full Changelog

Fixed bugs:

Merged pull requests:

  • Support reset extension in test engine #96 (akrambek)

0.9.29 (2022-08-29)

Full Changelog

Implemented enhancements:

  • Configurable isolation level for kafka binding #85
  • Configurable acknowledgement mode for kafka binding #84

Merged pull requests:

  • Support SSE proxy #98 (jfallows)
  • Enhance kafka transaction scenarios… #95 (jfallows)
  • Support read committed and read uncommitted kafka isolation levels #94 (jfallows)
  • Support configuration of produce acks #93 (jfallows)
  • Add tests for distinct partition leader #92 (akrambek)

0.9.28 (2022-07-12)

Full Changelog

Fixed bugs:

  • Scope topic partition leader info by both resolved binding and topic … #90 (jfallows)

0.9.27 (2022-07-09)

Full Changelog

Fixed bugs:

  • Investigate GitHub Actions build inconsistencies #23

Merged pull requests:

0.9.26 (2022-06-11)

Full Changelog

Merged pull requests:

  • Support produce with no reply-to directly to Kafka topic #79 (jfallows)

0.9.25 (2022-06-10)

Full Changelog

Fixed bugs:

  • Ignore query parameter in http-filesystem mapping… #77 (jfallows)

0.9.24 (2022-06-08)

Full Changelog

Fixed bugs:

  • Extract credentials from HTTP path query string even when non-terminal parameter #73
  • Malformed if-match value triggers exception #38

Merged pull requests:

  • Support query parameter in sse handshake #76 (jfallows)
  • Support path with query when routing http path conditions #75 (jfallows)
  • Use & as end of token separator for query parameter values #74 (jfallows)
  • Update README #72 (jfallows)
  • Add simple example and roadmap to README #70 (jfallows)
  • Include diagram in README #69 (jfallows)
  • Skip adding if-match header to kafka message if etag not present #67 (jfallows)

0.9.23 (2022-05-27)

Full Changelog

Merged pull requests:

  • Support trustcacerts without requiring a vault #66 (jfallows)
  • Check extension type id is proxy metadata in tls client and tcp client #64 (jfallows)
  • Ignore Github Actions test #62 (jfallows)

0.9.22 (2022-05-27)

Full Changelog

Fixed bugs:

  • Allow tls trustcacerts option to work without vault #65
  • Ws to tls proxy misinterprets begin extension #63

Merged pull requests:

0.9.21 (2022-05-25)

Full Changelog

Implemented enhancements:

  • Refer to sse-kafka event id progress as etag instead #43
  • Require exit be omitted from tcp client configuration #40

Fixed bugs:

  • Ensure single fan-in point for fan server... #57 (jfallows)

Merged pull requests:

  • Remove exit from tcp client binding schema #60 (jfallows)
  • Rename progress to etag in sse-kafka binding event id format #59 (jfallows)
  • Ignore Github Actions test #58 (akrambek)

0.9.20 (2022-05-24)

Full Changelog

Fixed bugs:

  • Clarify semantics of stream client index… #56 (jfallows)

Merged pull requests:

0.9.19 (2022-05-23)

Full Changelog

Merged pull requests:

  • Ensure single writer for kafka cache_server and echo server #53 (jfallows)
  • Describe Zilla in README.md #52 (jfallows)

0.9.18 (2022-05-23)

Full Changelog

Implemented enhancements:

  • Optimize transfer-encoding for http-kafka correlated response #45
  • Allow list of merged topics in kafka binding options to be optional #41

Fixed bugs:

  • Ensure kafka cache entry cannot grow... #49 (jfallows)

Merged pull requests:

  • Support merged topics across partitions by default … #51 (jfallows)
  • Use content-length instead of transfer-encoding chunked for correlated responses #50 (jfallows)
  • Use application/octet-stream as default content-type #47 (jfallows)
  • Ensure kafka producer stream has initialized with available window... #46 (jfallows)

0.9.17 (2022-05-13)

Full Changelog

Merged pull requests:

  • Support message trailers in kafka cache produce client #37 (jfallows)

0.9.16 (2022-05-12)

Full Changelog

Fixed bugs:

Merged pull requests:

  • Support idempotencyKey for http-kafka produce key #36 (jfallows)
  • Include content-length 0 on implicit 404 and 400 responses #35 (jfallows)
  • Support md5 hash of headers and payload to augment zilla:correlation-id #34 (jfallows)
  • Support M1 chip docker image #33 (akrambek)
  • Support SuppressWarnings annotation #32 (akrambek)
  • Support key and etag in event id #31 (jfallows)
  • Send SSE delete event for sse-kafka binding … #30 (jfallows)
  • Include content length 0 in explicit status 404 response #24 (jfallows)

0.9.15 (2022-05-12)

Full Changelog

Implemented enhancements:

  • Enhance http-kafka idempotency key #28
  • Support key in event id field for sse-kafka binding #27
  • Support etag in event id field for sse-kafka binding #26
  • Support tombstone messages via sse-kafka binding #25
  • http-kafka binding #17 (jfallows)

Fixed bugs:

  • Support default idempotency key and sync request response … #22 (jfallows)
  • Support initialSeq and initialAck being equal but non-zero #21 (jfallows)
  • Support omitting options from http-kafka binding config #20 (jfallows)

Merged pull requests:

  • Improve http-kafka get items scenarios … #19 (jfallows)
  • http binding implicit transfer-encoding chunked … #18 (jfallows)

0.9.14 (2022-03-26)

Full Changelog

Implemented enhancements:

0.9.13 (2022-03-25)

Full Changelog

Implemented enhancements:

  • Promote binding-filesystem and binding-http-filesystem from incubator #15 (jfallows)

0.9.12 (2022-03-25)

Full Changelog

Implemented enhancements:

  • Promote binding-sse-kafka from incubator #14 (jfallows)

0.9.11 (2022-03-24)

Full Changelog

0.9.10 (2022-03-24)

Full Changelog

0.9.9 (2022-03-24)

Full Changelog

Implemented enhancements:

Fixed bugs:

  • Improve coverage for sse binding deferred end and fix state transition bug #11 (jfallows)

Merged pull requests:

  • Test verify JWT roles when index differs #9 (jfallows)
  • Support CORS http/1.1 and http/2 #5 (jfallows)
  • Binding to map from SSE to Kafka #4 (jfallows)

0.9.8 (2022-01-31)

Full Changelog

0.9.7 (2022-01-20)

Full Changelog

0.9.6 (2022-01-15)

Full Changelog

0.9.5 (2022-01-14)

Full Changelog

0.9.4 (2022-01-13)

Full Changelog

0.9.3 (2022-01-13)

Full Changelog

0.9.2 (2022-01-13)

Full Changelog

0.9.1 (2022-01-12)

Full Changelog

0.9.0 (2022-01-12)

Full Changelog

0.8.2 (2022-01-10)

Full Changelog

0.8.1 (2022-01-10)

Full Changelog

0.8.0 (2022-01-07)

Full Changelog

0.7.0 (2022-01-02)

Full Changelog

0.6.0 (2022-01-01)

Full Changelog

0.5.2 (2021-12-30)

Full Changelog

0.5.1 (2021-12-29)

Full Changelog

0.5.0 (2021-12-29)

Full Changelog

Fixed bugs:

  • Mockito test failure only on GitHub Actions #3

0.4.0 (2021-12-17)

Full Changelog

0.3.0 (2021-12-17)

Full Changelog

0.2.0 (2021-12-17)

Full Changelog

0.1.0 (2021-12-16)

Full Changelog

* This Changelog was automatically generated by github_changelog_generator