bmaidics
bmaidics
In the mqtt.idl we have packetIds array but it's missing from the zilla dump result.
**To Reproduce** Steps to reproduce the behavior: 1. Start zilla latest develop with mqtt.kafka.broker config 2. `./emqtt_bench pub -t t -c 2 -L 4 -I 100 -p 7183 --prefix test...
``` Caused by: java.util.concurrent.CompletionException: java.lang.NullPointerException: Cannot invoke "String.length()" because "str" is null at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347) at java.base/java.util.concurrent.CompletableFuture$BiRelay.tryFire(CompletableFuture.java:1498) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147) at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.NamespaceTask.run(NamespaceTask.java:49) at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.onSystemSignal(EngineWorker.java:1105) at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.onSystemMessage(EngineWorker.java:1055) at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.handleRead(EngineWorker.java:1201)...
We should address all switch statements in MqttServerFactory for version 4 vs version 5 in the code each time an encoding decision is needed. We can use an inner class...
In KafkaCacheClientProduceFactory: ``` if ((flags & FLAGS_FIN) == 0x00 && deferred == 0) { error = ERROR_CORRUPT_MESSAGE; break init; } ``` we had this code which resets stream in cases...
**Describe the bug** k3po only matches the reply beginEx if the stream is in "connected" state. Even if we send it is misleadingly says that nothing arrived, as it only...
ReconfigureIT.shouldReconfigureWhenModifiedUsingComplexSymlinkChain is flaky on Github, it's failing rate is ~50%.
**Describe the bug** Zilla dump crashes with IndexOutOfBoundException when continuously recording packets at while Zilla runs in the background. **To Reproduce** Steps to reproduce the behavior: 1. Start zilla 2....
**Describe the bug** Sometimes Zilla crashes with IndexOutOfBoundsException when performing MQTT load test. **To Reproduce** Steps to reproduce the behavior: 1. Run Zilla locally with basic mqtt-kafka broker config 2....