Skip to content

Zilla crashes with IllegalArgumentException: cannot accept missingValue when using defaultOffset: live #1051

@vordimous

Description

@vordimous

Describe the bug
Zilla crashes with IllegalArgumentException: cannot accept missingValue when using defaultOffset: live in the sse.kafka.fanout zilla example

To Reproduce
Steps to reproduce the behavior:

  1. Using the sse.kafka.fanout example
  2. add the defaultOffset: live config option to the kafka cache_server
      topics:
        - name: events
          defaultOffset: live
  1. start the zilla exmple
  2. Zilla crashes with the below error
org.agrona.concurrent.AgentTerminationException: java.lang.IllegalArgumentException: cannot accept missingValue
    at io.aklivity.zilla.runtime.engine@0.9.80/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.doWork(EngineWorker.java:823)
    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:1583)
Caused by: java.lang.IllegalArgumentException: cannot accept missingValue
    at org.agrona.core/org.agrona.collections.Long2LongHashMap.putIfAbsent(Long2LongHashMap.java:271)
    at io.aklivity.zilla.runtime.binding.kafka@0.9.80/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaCacheBootstrapFactory$KafkaBootstrapStream.onPartitionLeaderReady(KafkaCacheBootstrapFactory.java:784)
    at io.aklivity.zilla.runtime.binding.kafka@0.9.80/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaCacheBootstrapFactory$KafkaBootstrapFetchStream.onFetchReplyBegin(KafkaCacheBootstrapFactory.java:1548)
    at io.aklivity.zilla.runtime.binding.kafka@0.9.80/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaCacheBootstrapFactory$KafkaBootstrapFetchStream.onFetchReply(KafkaCacheBootstrapFactory.java:1514)
    at io.aklivity.zilla.runtime.engine@0.9.80/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.handleDefaultReadReply(EngineWorker.java:1497)
    at io.aklivity.zilla.runtime.engine@0.9.80/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.handleReadReply(EngineWorker.java:1428)
    at io.aklivity.zilla.runtime.engine@0.9.80/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.handleRead(EngineWorker.java:1209)
    at io.aklivity.zilla.runtime.engine@0.9.80/io.aklivity.zilla.runtime.engine.internal.concurent.ManyToOneRingBuffer.read(ManyToOneRingBuffer.java:229)
    at io.aklivity.zilla.runtime.engine@0.9.80/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.doWork(EngineWorker.java:817)
    ... 4 more
    Suppressed: java.lang.Exception: [engine/data#3]        [0x030300000000001c] streams=[consumeAt=0x00003930 (0x0000000000003930), produceAt=0x00003b60 (0x0000000000003b60)]
            at io.aklivity.zilla.runtime.engine@0.9.80/io.aklivity.zilla.runtime.engine.internal.registry.EngineWorker.doWork(EngineWorker.java:821)
            ... 4 more

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions