- Notifications
You must be signed in to change notification settings - Fork62
0.9.126
Compare
Changelog
0.9.126 (2025-02-24)
Implemented enhancements:
- Type boolean possible in schema#1408
Fixed bugs:
- Java Agent Error while sending Data to Open Telemetry Endpoint (OTEL Endpoint)#1406
- Handle double quote when defining the table name in risingwave#1379
Merged pull requests:
- Handle double quote in z prefix resources#1412 (akrambek)
- Handle TLS Alert.USER_CANCELED then deferred Alert.CLOSE_NOTIFY#1411 (jfallows)
- support boolean model#1409 (ankitk-me)
- fix: resolveKind flow for composite binding#1407 (ankitk-me)
- fix: MQTT subscribe routing#1403 (ankitk-me)
- fix: mqtt-kafka routing fix#1402 (ankitk-me)
- fix: NPE due to empty Inline Catalog#1399 (ankitk-me)
- Append missing system schema to avoid exposing view in show command#1398 (akrambek)
- Bump lycheeverse/lychee-action from 2.2.0 to 2.3.0#1397 (dependabot[bot])
- Bump ubuntu from jammy-20240808 to jammy-20250126 in /cloud/docker-image/src/main/docker#1393 (dependabot[bot])
- Bump alpine from 3.21.0 to 3.21.2 in /cloud/docker-image/src/main/docker#1367 (dependabot[bot])
0.9.125 (2025-02-05)
Implemented enhancements:
- Support gRPC client streaming to Kafka directly#642
Fixed bugs:
- Zilla Crashes on invalid request payload#1394
- Schema Retrieval Failure Causes Validation Error in Zilla#1391
- Connection refused for MQTT Kafka broker after setting up TLS on the Kafka client#1389
- Zilla Validation not working correctly#1385
Merged pull requests:
- Use
OpenapiView
andAsyncapiView
to generate composite namespaces#1396 (jfallows) - fix: Zilla Crashes on invalid request payload#1395 (ankitk-me)
- fix: locale-specific formatting due to
MessageFormat.format()
#1390 (ankitk-me) - Support gRPC client stream/unary oneway#1384 (ankitk-me)
0.9.124 (2025-01-30)
Merged pull requests:
0.9.123 (2025-01-29)
Implemented enhancements:
- Allow separate Auth config for Catalog definitions#1195
Merged pull requests:
- Decode network unconditionally when received window on MQTT session stream#1386 (bmaidics)
- Support secure schema access#1369 (ankitk-me)
0.9.122 (2025-01-28)
Fixed bugs:
- Logging wrong accept url when http proxy is configured#1380
- Connection to MQTT server over WebSocket fails from web browser#1374
- Zilla unable to produce to Kafka when removing the north/south cache blocks#1353
Closed issues:
- Unify ZFUNCTION and ZSTREAM into a single concept#1376
Merged pull requests:
- Support configurable TLS client SNI validation and handle FQDNs …#1383 (jfallows)
- Log accepted before overriding the headers#1381 (akrambek)
- Unify ZFUNCTION and ZSTREAM into a single concept#1377 (akrambek)
0.9.121 (2025-01-20)
Merged pull requests:
0.9.120 (2025-01-20)
Merged pull requests:
- Make TLS client HTTPS endpoint identification configurable#1375 (jfallows)
- Fix checkstyle in TLS Server#1373 (ankitk-me)
0.9.119 (2025-01-20)
Merged pull requests:
0.9.118 (2025-01-12)
Merged pull requests:
- update extract
CN
logic to handle entry withCN
in any order#1368 (ankitk-me) - Bump lycheeverse/lychee-action from 2.1.0 to 2.2.0#1358 (dependabot[bot])
0.9.117 (2025-01-10)
Merged pull requests:
0.9.116 (2025-01-09)
Fixed bugs:
- Zilla is unresponsive sometimes & the app logs Stopped but accepts the CRUD requests#1312
- Asyncapi kafka header extraction expression don’t match zilla yaml expressions#1138
Merged pull requests:
- Minor bug fixes in zstream#1364 (akrambek)
- fix: kafka header extraction expression in composite zilla.yaml#1362 (ankitk-me)
- Support GSS encrypt request decoding as part of psql 14.15 client#1361 (akrambek)
- Zfunction and Zstream support#1354 (akrambek)
0.9.115 (2024-12-26)
Merged pull requests:
0.9.114 (2024-12-20)
Merged pull requests:
0.9.113 (2024-12-20)
Merged pull requests:
0.9.112 (2024-12-18)
Fixed bugs:
- Docs search bar doesn't work#1351
- InputMismatchException is thrown for
grpc
binding with googleapis/devtools/build proto#1230
Merged pull requests:
- Ztable support and convert transformation logic to state machine#1352 (akrambek)
- Improve gRPC parser to allow complex types in optionValue#1350 (bmaidics)
- Bump org.apache.avro:avro from 1.11.3 to 1.12.0#1290 (dependabot[bot])
0.9.111 (2024-12-13)
Implemented enhancements:
- Replace Ivy APIs for embedded Maven during
zpmw
install#1173
Merged pull requests:
0.9.110 (2024-12-13)
Merged pull requests:
0.9.109 (2024-12-13)
0.9.108 (2024-12-12)
Merged pull requests:
- Bump alpine from 3.20.3 to 3.21.0 in /cloud/docker-image/src/main/docker#1346 (dependabot[bot])
- Bump lycheeverse/lychee-action from 1.8.0 to 2.1.0#1325 (dependabot[bot])
- Bump actions/checkout from 3 to 4#1219 (dependabot[bot])
- Bump ubuntu from jammy-20240530 to jammy-20240808 in /cloud/docker-image/src/main/docker#1205 (dependabot[bot])
0.9.107 (2024-12-10)
Merged pull requests:
- Bump org.apache.avro:avro from 1.11.3 to 1.11.4#1284 (dependabot[bot])
- Bump com.google.protobuf:protobuf-java from 3.24.4 to 3.25.5 in /runtime/model-protobuf#1257 (dependabot[bot])
0.9.106 (2024-12-04)
Merged pull requests:
0.9.105 (2024-12-03)
Merged pull requests:
0.9.104 (2024-12-02)
Fixed bugs:
affinity mask must specify at least one bit
crash preventing Zilla from starting on Windows 11 + Docker Compose#1338
Merged pull requests:
0.9.103 (2024-11-27)
Fixed bugs:
- Mqtt selecting incorrect publish stream#1327
Merged pull requests:
- resolve nested
$ref
in schema#1337 (ankitk-me) - Enhance test vault and test exporter#1333 (jfallows)
- validate
begin
frame type forws
client#1332 (ankitk-me) - Support
directory
syntax & functionality#1323 (ankitk-me)
0.9.102 (2024-11-13)
Implemented enhancements:
- Support
risingwave
pgsql
message transformations#1208
Merged pull requests:
- Fix MQTT binding selecting incorrect publish stream#1328 (bmaidics)
- Support ALTER STREAM and ALTER TABLE transformation#1320 (akrambek)
0.9.101 (2024-11-07)
Fixed bugs:
- Running emqtt_bench triggers exception in KafkaCacheCursorFactory#752
Closed issues:
- Support
ALTER STREAM
andALTER TABLE
transformation#1319
Merged pull requests:
- Support instrumentation via Java agent#1321 (jfallows)
number
->integer
formax-age
attribute#1316 (ankitk-me)- support file write in binding-filesystem & binding-http-filesystem#1300 (ankitk-me)
0.9.100 (2024-10-29)
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:
Merged pull requests:
- Support asyncapi server variables locally and via references#1314 (jfallows)
- Support
https
scheme for zilla.yaml config watcher#1313 (jfallows) - Add missing dependency#1311 (akrambek)
- Fix kafka cache fetch server retention issue#1310 (bmaidics)
- pgsql ALTER TOPIC command to register new schema#1309 (akrambek)
- Fix IndexOutOfBoundsException at KafkaCacheClientProduceFactory#1303 (bmaidics)
- Log missing enviroment variables#1299 (ankitk-me)
- Replace jsqlparser with antlr gramma#1298 (akrambek)
- syntax check mqtt topic names in zilla.yaml#1297 (ankitk-me)
- Include prefer wait in watch request even after initial 404 read request#1295 (jfallows)
- protobuf validation failure fix#1292 (ankitk-me)
- Upgrade agrona version#1281 (bmaidics)
- Support DROP TABLE, STREAM, and MATERIALIZED VIEW#1266 (akrambek)
0.9.99 (2024-10-12)
Merged pull requests:
- Update advertised protocol version in pgsql server binding#1294 (akrambek)
- Support cancel request#1293 (akrambek)
0.9.98 (2024-10-10)
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)
Implemented enhancements:
- Support
jwt
guarded identity via custom token claim#1276 - Support
insert into
to seedkafka
messages viarisingwave
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)
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:
- Risingwave SInk primary key fix#1273 (akrambek)
- Risingwave and PsqlKafka bug fixes#1272 (akrambek)
- create external function issue fix#1271 (ankitk-me)
- Remove produceRecordFramingSize constraints#1270 (akrambek)
- External header pattern fix#1269 (ankitk-me)
- Detect config update after initial 404 status#1267 (jfallows)
- Support Kafka topics alter, delete#1265 (akrambek)
0.9.95 (2024-09-23)
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:
- Fix KafkaMerged evaluation storage#1264 (bmaidics)
- Bump alpine from 3.20.2 to 3.20.3 in /cloud/docker-image/src/main/docker#1235 (dependabot[bot])
0.9.94 (2024-09-21)
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:
- Fix parsing newline before end of stream#1262 (akrambek)
- Support embedded risngwave functions#1261 (akrambek)
- Explicitly set http version for schema registration#1260 (akrambek)
- Support risingwave include keyword#1259 (akrambek)
- Use END instead of ABORT at network end in MQTT#1256 (bmaidics)
- Risingwave demo bug fixes#1254 (akrambek)
- fix: use integer for challenge type#1252 (vordimous)
- fix: add or update the transforms pattern regex#1251 (vordimous)
- Describe cluster API Support#1250 (akrambek)
- Fix mqtt abort issue#1249 (bmaidics)
- create
function
support inrisingwave
binding#1248 (ankitk-me) - Ensure extract-key precedes extract-headers …#1247 (jfallows)
- Support catalog register new schema version#1246 (akrambek)
- Support pgsql-kafka binding#1245 (akrambek)
zilla
build fix#1242 (ankitk-me)- fix: NPE when a schema isn't found in a schema registry#1241 (ankitk-me)
- Initialize pgsql-kafka binding#1239 (jfallows)
- Support Kafka topic create, alter, delete#1234 (akrambek)
- fix: fix schema syntax and naming#1217 (vordimous)
risingwave
binding support#1211 (akrambek)
0.9.93 (2024-09-10)
Implemented enhancements:
- Support
pgsql
binding#1057 - Handle large HTTP headers#1046
- Gracefully handle
zilla.yml
instead ofzilla.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
inasyncapi
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:
- Refactor vault handler#1236 (jfallows)
- Mqtt flow control fix#1233 (bmaidics)
- Fix incorrect flush acknowledgement in KafkaCacheClientProduceFactory#1232 (bmaidics)
- http binding update to support header overrides at route level#1231 (ankitk-me)
- Update asyncapi binding module-info to open parser package#1227 (jfallows)
- Link checker#1216 (vordimous)
- Fix incorrect CRC combine in Kafka produce client#1214 (bmaidics)
- Reduce compile warnings#1213 (jfallows)
- Eclipse IDE import maven projects#1212 (jfallows)
- Disable JVM class sharing to avoid error message during build#1210 (jfallows)
- Initial risingwave binding projects#1209 (jfallows)
- Ensure id encoding is consistent for encode and decode#1204 (jfallows)
- Update mqtt session stream to report correct origin id for zilla dump command#1203 (jfallows)
- Support pgsql binding#1200 (akrambek)
- Initial pgsql binding projects#1198 (jfallows)
- Fix: Using
asyncapi client
binding trigger NPE & crashes Zilla#1197 (ankitk-me) - Compute kafka produce checksum without staging headers#1196 (jfallows)
- Allow content-length header with h2c upgrade#1194 (jfallows)
- Kafka cache client: mark entry dirty at flush before notifying the server to process#1193 (bmaidics)
- Ensure streams are cleaned up on authentication failure…#1191 (jfallows)
0.9.92 (2024-08-13)
Implemented enhancements:
- Support
extract-key
kafka message transform#1176
Merged pull requests:
- Align subject names when using inline catalog#1190 (jfallows)
- Support extract-key kafka message transform#1183 (akrambek)
0.9.91 (2024-08-10)
Fixed bugs:
asyncapi
binding triggers zilla crash when used withcatalog::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 usecatalog::apicurio
#1186 (ankitk-me)
0.9.90 (2024-08-05)
Implemented enhancements:
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 requirevault
andkeys
orsigners
inoptions
#1159 (ankitk-me)
0.9.89 (2024-07-22)
Implemented enhancements:
- Support
asyncapi
mappingsse
protocol tokafka
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:
- Kafka debug log fix#1163 (ankitk-me)
- grpc: mutable byte arrays to non-static instance fields#1160 (ankitk-me)
- Avro validation bug fix#1157 (ankitk-me)
- custom metadata populated by grpc-server missing fix#1156 (ankitk-me)
- Support karapace-schema-registry, schema-registry and apicurio-registry catalogs#1134 (jfallows)
- grpc custom metadata passthrough implementation#1097 (ankitk-me)
0.9.88 (2024-07-15)
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)
Merged pull requests:
0.9.86 (2024-07-10)
Merged pull requests:
0.9.85 (2024-07-10)
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:
- Ensure SASL handshake occurs for JoinGroupRequest as needed…#1139 (jfallows)
- Add CatalogConfig.builder() methods#1133 (jfallows)
- Lint helm chart on local builds and PR builds#1132 (jfallows)
- fix: Add custom pod labels and fix notes for connection instructions#1130 (vordimous)
- Detect missing events in test exporter#1128 (jfallows)
- Enhance Kafka event descriptions#1127 (jfallows)
- Bug fixes and improvements to support asyncapi http, sse, and kafka integration#1124 (akrambek)
- Add zilla version command#1121 (bmaidics)
- Support reentrant kafka write key for converter#1120 (jfallows)
- Enhance TLS key pair verification tests#1119 (jfallows)
- Bump alpine from 3.20.0 to 3.20.1 in /cloud/docker-image/src/main/docker#1102 (dependabot[bot])
0.9.84 (2024-06-29)
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:
- Use default config when missing#1118 (jfallows)
- Require test exporter event properties via test schema#1117 (jfallows)
- Include engine test sources JAR in release#1116 (jfallows)
- Generate asyncapi schema catalog with avro, protobuf format support#1113 (akrambek)
- Add logging of cluster authorization failed error to kafka binding#1112 (attilakreiner)
- Verify public-private tls key pair#1108 (attilakreiner)
0.9.83 (2024-06-28)
Implemented enhancements:
- Add asyncapi http-kafka proxy example#1077
- Use miliseconds in metrics#1069
- Promote
filesystem
catalog out of incubator#1068 - Support
asyncapi
mappinghttp
protocol tokafka
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 viaasyncapi
#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:
- Refactor signaler class name#1111 (jfallows)
- fix: add volume mounts into the deployment yaml#1110 (vordimous)
- Support engine events and detect config watcher failed#1107 (jfallows)
- Support special characters for resolving channel ref#1101 (akrambek)
- Fix NegativeArraySizeException when receiving mqttFlush#1100 (bmaidics)
- Asyncapi sse kafka proxy#1099 (bmaidics)
- Fix dump mqtt session begin#1098 (attilakreiner)
- Promote catalog-filesystem out of incubator#1096 (attilakreiner)
- Fix imports#1095 (attilakreiner)
- Implement millisecond conversion to metrics#1094 (attilakreiner)
- filtering by structured value field(s)#1093 (ankitk-me)
- Add sse payload validation#1092 (bmaidics)
- Ensure engine closes after stdout generated#1091 (jfallows)
- Await non-empty output before verifying expected vs actual#1090 (jfallows)
- Ensure stdout flush without newline before comparison to expected output#1089 (jfallows)
- Upgrade zilla docker image to use jdk 22#1088 (jfallows)
- Update k3po dependency#1086 (jfallows)
- SSE asyncapi server, client#1085 (bmaidics)
- Java 17 source compatibility#1084 (jfallows)
- Bump ubuntu from jammy-20240427 to jammy-20240530 in /cloud/docker-image/src/main/docker#1079 (dependabot[bot])
- Dynamic decode padding by length fix#1078 (ankitk-me)
- Catalog Handler interface to support dynamic encode padding by length#1075 (ankitk-me)
- Fix mqtt-kafka non compact test#1074 (bmaidics)
- Http-Kafka AsyncAPI#1072 (bmaidics)
- Support remote zilla configuration with change detection#1071 (attilakreiner)
- feat: replace port 8080 with 12345#1070 (vordimous)
- Fix NPE when trying to resolve guards#1067 (attilakreiner)
- Add publish qos max options for mqtt-kafka binding#1065 (bmaidics)
- Added declarative helmfile#1054 (ttimot24)
- Bump alpine from 3.19.1 to 3.20.0 in /cloud/docker-image/src/main/docker#1047 (dependabot[bot])
- Fix TlsNetworkIT by adding cipherSuites#1043 (attilakreiner)
- feat: replace static event name with dynamic based on event id#1029 (vordimous)
0.9.82 (2024-05-28)
Fixed bugs:
- Zilla crashes with
IllegalArgumentException: cannot accept missingValue
when usingdefaultOffset: live
#1051 - Zilla crashes on mqtt cli -T option#1039
- Running
emqtt_bench
bothsub
andpub
triggers an exception#1000 http-kafka
willfetch
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)
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 accesshttps://localhost:9090
#975
Merged pull requests:
- Add service.name attribute to metrics#1048 (attilakreiner)
- Starting Zilla with the CLI improvement#1042 (ankitk-me)
- Sort frames by timestamp in dump command#1041 (attilakreiner)
- Ensure new mqtt subscriptions are not empty#1040 (jfallows)
- Add zilla context to MQTT consumer groups#1035 (bmaidics)
- Split protocol testing into separate ITs for zilla dump command#989 (attilakreiner)
0.9.80 (2024-05-20)
Breaking changes:
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
andasyncapi
bindings#950 - Support multiple specs in
openapi
binding#949 - Support multiple specs in
asyncapi
binding#948 - Support
asyncapi
mqtt
streetlights mapping tokafka
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 viahomebrew
#680 - Update bug report template#820 (vordimous)
Fixed bugs:
- Zilla crashes with
IllegalArgumentException
when an Avro payload is fetched asjson
#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 configuredremote_server
#882 - Using the
grpc.kafka.proxy
example setup, Zilla will periodically not deliver the message to the gRPC service defined in thekafka-grpc
binding#881 - Flaky kafka-grpc test#768
Merged pull requests:
- Handle & calculate complex schema padding#1038 (ankitk-me)
- Fix typo to send abort on abort instead of end#1036 (akrambek)
- Bump junit.version from 5.10.1 to 5.10.2#1032 (dependabot[bot])
- Honor MQTT clean start at QoS2 produce#1031 (bmaidics)
- Use flyweight fields instead of class fields for control#1030 (akrambek)
- catalog:apicurio - unify caching across workers to maximize cache hits#1027 (ankitk-me)
- Use binding id instead of route Id for resolved Id#1026 (akrambek)
- MQTT clients access log implementation#1023 (ankitk-me)
- Unsubscribe on partition reassignment#1021 (akrambek)
- Bump commons-cli:commons-cli from 1.6.0 to 1.7.0#1020 (dependabot[bot])
- Increase mqtt client id limit to 256#1015 (bmaidics)
- Generate correct crc32c value for the messages with different produceId#1011 (akrambek)
- Remove generate command#1010 (attilakreiner)
- Support configuration of timestamps in zilla transport for k3po#1009 (jfallows)
- Support multiple specs in openapi-asyncapi binding#1008 (bmaidics)
- Support multiple specs in openapi binding#1005 (bmaidics)
- Fix secure http detection in OpenAPI#1002 (bmaidics)
- Enhancing validation for openapi and asyncapi bindings#1001 (ankitk-me)
- Support asyncapi mqtt streetlights mapping to kafka streetlights#997 (bmaidics)
- Bump ubuntu from jammy-20240416 to jammy-20240427 in /cloud/docker-image/src/main/docker#996 (dependabot[bot])
- Bump org.bitbucket.b_c:jose4j from 0.9.3 to 0.9.6#995 (dependabot[bot])
- MQTT Websocket bugfix#993 (bmaidics)
- Add MQTT client authentication#992 (bmaidics)
tls
client/server/echo
handshake benchmark#990 (akrambek)- Bump ubuntu from jammy-20240111 to jammy-20240416 in /cloud/docker-image/src/main/docker#987 (dependabot[bot])
- Bump alpine from 3.19.0 to 3.19.1 in /cloud/docker-image/src/main/docker#986 (dependabot[bot])
- Update Java build matrix#983 (jfallows)
- Support multiple specs in asyncapi binding#982 (bmaidics)
- Remove event script in favor of handshake script#981 (attilakreiner)
echo
server
handshake benchmark#980 (akrambek)- MqttKafka publish intern fix#979 (bmaidics)
- Fix multiple exporters issue#978 (attilakreiner)
- unify caching across workers to maximize cache hits#977 (ankitk-me)
- Support reading empty file payload#976 (jfallows)
- Use format to construct get openapi operation for async rquest#967 (akrambek)
- binding config schema validation for unused properties#929 (ankitk-me)
- Bump org.agrona:agrona from 1.6.0 to 1.21.1#890 (dependabot[bot])
0.9.79 (2024-04-22)
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:
Merged pull requests:
- Support config for mqtt publish qos max#971 (jfallows)
- Use default kafka client id for kafka client instance id#968 (jfallows)
- Add vault parameter to exporter#966 (attilakreiner)
- Implement filesystem catalog#962 (bmaidics)
0.9.78 (2024-04-16)
Merged pull requests:
- Ensure binding types are populated for
zilla dump
to dissect protocol-specific frames#928 (attilakreiner)
0.9.77 (2024-04-15)
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)
Merged pull requests:
- IT to validate null message in binding-kafka with Model configured#925 (ankitk-me)
- Convert non-null payloads only, …#923 (jfallows)
- Fix validation bug#922 (akrambek)
- Fix helm chart logo URL#920 (attilakreiner)
0.9.75 (2024-04-12)
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
andasyncapi
withcatalog
#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:
- Fix remaing jwt issues#918 (akrambek)
- Promote components out of incubator#917 (jfallows)
- Ignore case while checking guard type#916 (akrambek)
- Handle race condition between k3po and engine…#915 (jfallows)
- Add apicurio latest version test#914 (bmaidics)
- Fix pom.xml for helm-chart#912 (attilakreiner)
- openapi-asyncapi route bug fixes#911 (akrambek)
- Use per worker registration for composite namespaces#910 (jfallows)
- Fix schema validation parsing#909 (akrambek)
- Support latest version in Apicurio#907 (bmaidics)
- Remove name from asyncapi.specs.servers#906 (bmaidics)
- Update schema to fix leaking implementation details#904 (ankitk-me)
- Update helm chart#901 (attilakreiner)
- Integrate openapi and asyncapi with catalog#900 (akrambek)
- Support HTTP prefer async with OpenAPI#899 (akrambek)
- Asyncapi mqtt improvements#898 (bmaidics)
- Support karapace catalog#893 (bmaidics)
- Support BindingConfig attach and detach of composite namespaces#892 (jfallows)
- Cleanup warnings for JDK 21 tools#891 (jfallows)
- zilla crash while using model-json and schema is not found#889 (ankitk-me)
- Support specific server in OpenAPI spec in openapi binding#888 (akrambek)
- Support specific server in AsyncAPI spec in asyncapi binding#883 (bmaidics)
- Number Validator improvement to support OpenAPI & AsyncAPI specs#875 (ankitk-me)
- Event logs for Model#874 (ankitk-me)
- String Validator improvement to support OpenAPI & AsyncAPI specs#873 (ankitk-me)
- Schema fixes + avoiding duplicate reply begin on mqtt-kafka subscribe stream#872 (bmaidics)
- Support logging of schema without expressions#871 (jfallows)
- Fix metrics#869 (attilakreiner)
- Support metrics in openapi and asyncapi#868 (akrambek)
- Update README.md#867 (llukyanov)
- Integer Validator improvement to support OpenAPI & AsyncAPI specs#830 (ankitk-me)
0.9.74 (2024-03-19)
Merged pull requests:
- Fix http header value offset#865 (akrambek)
- Support non-404 status codes on authorization failure#864 (jfallows)
0.9.73 (2024-03-18)
Merged pull requests:
- Read buffer pool size from file when readonly#863 (jfallows)
- Resolve top level namespace guards in composite namespaces#862 (jfallows)
- Openapi bug fixes#861 (akrambek)
- Populate guarded qname for composite namespaces#860 (jfallows)
- Fix qvault on asyncapi composite binding#858 (bmaidics)
- Support guarded qname for composite namespaces#857 (jfallows)
0.9.72 (2024-03-17)
Merged pull requests:
- Log http access event before validation in both http/1.1 and h2#856 (jfallows)
- Fail when failed to acquire budget index#855 (bmaidics)
- Conditionally release buffer slot on clean up#854 (akrambek)
- Fix exporter-otlp schema#852 (attilakreiner)
0.9.71 (2024-03-15)
Implemented enhancements:
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)
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:
- Fix options name, port resolving#833 (bmaidics)
- Stabilize Asyncapi test with race condition#832 (bmaidics)
- Simplify zilla shell script logic for sh on container images#831 (jfallows)
- Fix NPE in connection pool due to race condition#828 (akrambek)
- Refactoring event logs#821 (attilakreiner)
0.9.69 (2024-03-04)
Implemented enhancements:
- Use dedicated env var to enable Incubator features#800
- Support
http
tokafka
proxy usingopenapi.yaml
andasyncapi.yaml
#742 - Support
mqtt
tokafka
proxy usingasyncapi.yaml
#741 - Support
openapi
http
proxy usingopenapi.yaml
#740 - Support
asyncapi
http
proxy usingasyncapi.yaml
#739 - Support
asyncapi
mqtt
proxy usingasyncapi.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:
- Asyncapi and Openapi bug fixes#826 (akrambek)
- Asyncapi catalog implementation#825 (bmaidics)
- Fix NPE in KafkaSignalStream#823 (bmaidics)
- Fix early flush sending for retained stream#822 (bmaidics)
- Add incubating annotation for stdout exporter#819 (jfallows)
- MQTT-Kafka asyncapi proxy#818 (bmaidics)
- Fix kafka client composite resolvedId#816 (bmaidics)
- Use env var to add incubator java option#811 (vordimous)
- Support http to kafka proxy using openapi.yaml and asyncapi.yaml#810 (akrambek)
- Structured models require
catalog
config#807 (ankitk-me) - Include qualified vault name on binding#806 (jfallows)
- Include config exception cause#805 (jfallows)
- Kafka asyncapi client#804 (bmaidics)
- Support k3po ephemeral option#801 (akrambek)
- Support asyncapi http proxy using asyncapi.yaml#799 (bmaidics)
- Fix kafka sasl schema validation to support expressions#798 (akrambek)
- Zilla is validating env vars before replacing them#797 (akrambek)
- Support openapi http proxy using openapi.yaml#778 (akrambek)
- Support asyncapi mqtt proxy using asyncapi.yaml#764 (bmaidics)
- Support local logging of events#755 (attilakreiner)
0.9.68 (2024-02-13)
Fixed bugs:
- Zilla crashes when a large number of MQTT clients connect#793
Merged pull requests:
0.9.67 (2024-02-11)
Implemented enhancements:
- Use
model
andview
when describing the message type#750 - Support obtaining
protobuf
schemas fromschema registry
forgrpc
services#697 - Support idempotent
mqtt
qos 2
publish tokafka
#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 tomqtt v5
#708tls binding
should handlenull
key returned fromvault
#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:
- Simplify TLSv1.3 handshake check#792 (jfallows)
- Support TLSv1.3 handshake completion#790 (jfallows)
- Refactor NamespacedId to public API#789 (jfallows)
- Align affinity for kafka group coordinator#788 (jfallows)
- Log validation failure of HTTP messages (stdout)#781 (ankitk-me)
- Supply client id by host only, and move defaulting to caller#780 (jfallows)
- Handle unknown vault keys in tls binding#779 (jfallows)
- Refactor to use kafka server config per client network stream…#777 (jfallows)
- update docker-image pom.xml to refer model modules#775 (ankitk-me)
- Skip invalid Kafka messages during Fetch#774 (ankitk-me)
- Refactoring supplyValidator to MqttServerFactory#773 (ankitk-me)
- TTL based cache update cleanup#772 (ankitk-me)
- HTTP response bug fix and other minor refactoring#769 (ankitk-me)
- Model specific cache detect schema change update#767 (ankitk-me)
- feature/schema-registry catchup with develop#765 (ankitk-me)
- model and view changes#763 (ankitk-me)
- Json Fragment Validator Implementation#761 (ankitk-me)
- Support obtaining protobuf schemas from schema registry for grpc services#757 (akrambek)
- Bump actions/cache from 3 to 4#748 (dependabot[bot])
- Fragment validator interface & implementation#735 (ankitk-me)
- Qos2 idempotent producer#733 (bmaidics)
- Mqtt-kafka single group support cont#731 (akrambek)
- migrating from Validator to Converter#729 (ankitk-me)
- Catch up dump command with kafka extension changes#728 (attilakreiner)
- Improve mqtt-kafka to use only one kafka consumer group per mqtt client.#727 (akrambek)
- Protobuf Validation & Conversion#691 (ankitk-me)
- Validator Interface Update & Converter Changes#533 (ankitk-me)
0.9.66 (2024-01-24)
Implemented enhancements:
- Support
openapi
http
response validation#684 - Support
protobuf
conversion to and fromjson
forkafka
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)
Implemented enhancements:
- Support
avro
conversion to and fromjson
forkafka
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 thetls
binding#564 - Support outbound message transformation from
protobuf
tojson
#458 - Support inbound message transformation from
json
toprotobuf
#457 - Support outbound message transformation from
avro
tojson
#315 - Support inbound message transformation from
json
toavro
#313 - Handle data fragmentation for MQTT binding#282
- separating publish streams based on qos#726 (bmaidics)
- Add
sse
,ws
,fs
extension parsing todump
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 permqtt
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:
Merged pull requests:
- Bump ubuntu from jammy-20231128 to jammy-20240111 in /cloud/docker-image/src/main/docker/incubator#747 (dependabot[bot])
- Bump ubuntu from jammy-20231128 to jammy-20240111 in /cloud/docker-image/src/main/docker/release#746 (dependabot[bot])
- Support composite binding config#737 (jfallows)
- Add amqp extension parsing to dump command#723 (attilakreiner)
- Suppress checkstyle for generated sources#721 (jfallows)
- Ignore line length check for import and package statements#720 (jfallows)
- Bump com.fasterxml.jackson.dataformat:jackson-dataformat-yaml from 2.15.2 to 2.16.1#718 (dependabot[bot])
- Bump byteman.version from 4.0.21 to 4.0.22#717 (dependabot[bot])
- Http1 server not progressing after reaching full buffer slot size#714 (akrambek)
- Bump org.apache.maven:maven from 3.9.4 to 3.9.6#712 (dependabot[bot])
- Bump org.apache.maven.plugins:maven-compiler-plugin from 3.11.0 to 3.12.1#711 (dependabot[bot])
- Simplify kafka client bootstrap server names and ports config#710 (akrambek)
- Align tcp net read window#709 (jfallows)
- Add kafka extension parsing to dump command#706 (attilakreiner)
- Bump org.codehaus.mojo:exec-maven-plugin from 3.1.0 to 3.1.1#703 (dependabot[bot])
- Bump org.jacoco:jacoco-maven-plugin from 0.8.10 to 0.8.11#701 (dependabot[bot])
- Unnecessary deferred value causes the connection to stall#700 (akrambek)
- Refactor dispatch agent#699 (jfallows)
- Reset back initial max once ack is fully caught up with seq#696 (akrambek)
- Add mqtt extension parsing to dump command#695 (attilakreiner)
- Reject stream if deferred is not set for the fragmented message#693 (akrambek)
- Remove wrong state assignment in the group cache#692 (akrambek)
- Bump org.moditect:moditect-maven-plugin from 1.0.0.Final to 1.1.0#688 (dependabot[bot])
- Bump commons-cli:commons-cli from 1.3.1 to 1.6.0#687 (dependabot[bot])
- Bump junit.version from 5.8.2 to 5.10.1#686 (dependabot[bot])
- Bump jakarta.json:jakarta.json-api from 2.0.1 to 2.1.3#674 (dependabot[bot])
- Bump jmh.version from 1.12 to 1.37#673 (dependabot[bot])
- Bump com.guicedee.services:commons-collections4 from 1.1.0.7 to 1.2.2.1#672 (dependabot[bot])
- Bump org.mockito:mockito-core from 5.3.1 to 5.8.0#665 (dependabot[bot])
- Bump org.slf4j:slf4j-api from 1.7.36 to 2.0.10#664 (dependabot[bot])
- Bump org.hamcrest:hamcrest-library from 1.3 to 2.2#663 (dependabot[bot])
- Update latest and stable offset if it was in stabilizing state#661 (akrambek)
- Release kafka connection pool budget#659 (akrambek)
- Handle large message in grpc#649 (akrambek)
- Feature/tls ports#591 (lukefallows)
- Bump eclipse-temurin from 20-alpine to 21-alpine in /cloud/docker-image/src/main/docker/release#506 (dependabot[bot])
- Bump eclipse-temurin from 20-jdk to 21-jdk in /cloud/docker-image/src/main/docker/incubator#505 (dependabot[bot])
- Bump org.slf4j:slf4j-simple from 1.7.21 to 2.0.9#392 (dependabot[bot])
- Bump com.github.biboudis:jmh-profilers from 0.1.3 to 0.1.4#385 (dependabot[bot])
- Bump org.eclipse:yasson from 2.0.3 to 3.0.3#346 (dependabot[bot])
0.9.64 (2023-12-25)
Merged pull requests:
- MQTT topic sharding#657 (jfallows)
- Move everything except fetch and produce to use connection pool#656 (akrambek)
0.9.63 (2023-12-25)
Implemented enhancements:
- Support MQTT message expiry in
mqtt-kafka
mapping#631 - Add grpc extension parsing to the dump command#652 (attilakreiner)
- Add end-to-end testing for the
dump
command#646 (attilakreiner) - Implement mqtt message expiry#640 (bmaidics)
- Improve server sent DISCONNECT reasonCodes#634 (bmaidics)
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)
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)
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)
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 requestvalidators
fromOpenAPI
specification#459 - MQTT 3.1.1 implementation#582 (bmaidics)
Fixed bugs:
- the
tls
binding throws NPE if there are nooptions
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 andtcp
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)
Implemented enhancements:
- Generate
http
server requestvalidators
fromAsyncAPI
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:
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)
Implemented enhancements:
- Integrate
http
binding withvalidators
#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)
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)
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)#257OpenAPI
integration (baseline)#255mqtt-kafka
feature (baseline)#190telemetry metrics
feature (baseline)#188grpc-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)
Implemented enhancements:
- Use 1-1 helm chart versioning strategy#487
- Generate
mqtt
server publishvalidators
fromAsyncAPI
specification#461 - Integrate
mqtt
binding withvalidators
#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 incorrectDATA
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)
Assets2
Uh oh!
There was an error while loading.Please reload this page.