[Connection Pool] Signaling can trigger exception

[akrambek]

2023-10-31 13:44:55 org.agrona.concurrent.AgentTerminationException: java.util.NoSuchElementException
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.doWork(DispatchAgent.java:707)
2023-10-31 13:44:55     at org.agrona.core/org.agrona.concurrent.AgentRunner.doDutyCycle(AgentRunner.java:291)
2023-10-31 13:44:55     at org.agrona.core/org.agrona.concurrent.AgentRunner.run(AgentRunner.java:164)
2023-10-31 13:44:55     at java.base/java.lang.Thread.run(Thread.java:1623)
2023-10-31 13:44:55 Caused by: java.util.NoSuchElementException
2023-10-31 13:44:55     at org.agrona.core/org.agrona.collections.LongArrayQueue.removeLong(LongArrayQueue.java:319)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientConnection.doConnectionWindow(KafkaClientConnectionPool.java:1281)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientStream.flushStreamWindow(KafkaClientConnectionPool.java:886)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientStream.onStreamWindow(KafkaClientConnectionPool.java:783)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientStream.onStreamSignal(KafkaClientConnectionPool.java:1009)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientConnection.onConnectionSignal(KafkaClientConnectionPool.java:1473)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientConnectionPool$KafkaClientConnection.onConnectionMessage(KafkaClientConnectionPool.java:1334)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.handleReadInitial(DispatchAgent.java:1119)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.handleRead(DispatchAgent.java:1041)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.concurent.ManyToOneRingBuffer.read(ManyToOneRingBuffer.java:181)
2023-10-31 13:44:55     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.doWork(DispatchAgent.java:701)
2023-10-31 13:44:55     ... 3 more
2023-10-31 13:44:55     Suppressed: java.lang.Exception: [engine/data#9]        [0x09090000000001a3] streams=[consumeAt=0x000fd730 (0x000000000bcfd730), produceAt=0x000fd848 (0x000000000bcfd848)]
2023-10-31 13:44:55             at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.doWork(DispatchAgent.java:705)