-
Notifications
You must be signed in to change notification settings - Fork 71
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
Describe the bug
Zilla crashes with IndexOutOfBoundException at produce with reply capability if message > 8kb
org.agrona.concurrent.AgentTerminationException: java.lang.IndexOutOfBoundsException: index=0 length=10351 capacity=8192
at io.aklivity.zilla.runtime.engine@0.9.139/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.doWork(EngineWorker.java:858)
at org.agrona.core/org.agrona.concurrent.AgentRunner.doWork(AgentRunner.java:304)
at org.agrona.core/org.agrona.concurrent.AgentRunner.workLoop(AgentRunner.java:296)
at org.agrona.core/org.agrona.concurrent.AgentRunner.run(AgentRunner.java:162)
at java.base/java.lang.Thread.run(Thread.java:1570)
Caused by: java.lang.IndexOutOfBoundsException: index=0 length=10351 capacity=8192
at org.agrona.core/org.agrona.BufferUtil.boundsCheck(BufferUtil.java:97)
at org.agrona.core/org.agrona.AbstractMutableDirectBuffer.getBytes(AbstractMutableDirectBuffer.java:457)
at io.aklivity.zilla.runtime.binding.http.kafka@0.9.139/io.aklivity.zilla.runtime.binding.http.kafka.internal.config.HttpKafkaWithProduceHash.updateHash(HttpKafkaWithProduceHash.java:47)
at io.aklivity.zilla.runtime.binding.http.kafka@0.9.139/io.aklivity.zilla.runtime.binding.http.kafka.internal.config.HttpKafkaWithProduceResult.updateHash(HttpKafkaWithProduceResult.java:110)
at io.aklivity.zilla.runtime.binding.http.kafka@0.9.139/io.aklivity.zilla.runtime.binding.http.kafka.internal.stream.HttpKafkaProxyFactory$HttpProduceSyncProxy.onHttpData(HttpKafkaProxyFactory.java:3789)
at io.aklivity.zilla.runtime.binding.http.kafka@0.9.139/io.aklivity.zilla.runtime.binding.http.kafka.internal.stream.HttpKafkaProxyFactory$HttpProduceSyncProxy.onHttpMessage(HttpKafkaProxyFactory.java:3693)
at io.aklivity.zilla.runtime.engine@0.9.139/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.handleReadInitial(EngineWorker.java:1277)
at io.aklivity.zilla.runtime.engine@0.9.139/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.handleRead(EngineWorker.java:1244)
at io.aklivity.zilla.runtime.engine@0.9.139/io.aklivity.zilla.runtime.engine.internal.concurent.ManyToOneRingBuffer.read(ManyToOneRingBuffer.java:229)
at io.aklivity.zilla.runtime.engine@0.9.139/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.doWork(EngineWorker.java:852)
... 4 more
Suppressed: java.lang.Exception: [engine/data#9] [0x0909000000000037] streams=[consumeAt=0x00018f30 (0x0000000000018f30), produceAt=0x00018fe8 (0x0000000000018fe8)]
at io.aklivity.zilla.runtime.engine@0.9.139/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.doWork(EngineWorker.java:856)
To Reproduce
Steps to reproduce the behavior:
- Use http.kafka.oneway example, but add
reply-to: responseto http-kakfa mapping - use curl to POST a message > 8kb
- See error
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working