Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Gracefully handle out of slot exception in kafka cache client produce #558

Closed
akrambek opened this issue Nov 1, 2023 · 0 comments · Fixed by #561
Closed

Gracefully handle out of slot exception in kafka cache client produce #558

akrambek opened this issue Nov 1, 2023 · 0 comments · Fixed by #561
Labels
bug Something isn't working

Comments

@akrambek
Copy link
Contributor

akrambek commented Nov 1, 2023 

2023-11-01 13:27:02 Caused by: java.lang.IllegalArgumentException: invalid offset: -65536
2023-11-01 13:27:02     at org.agrona.core/org.agrona.concurrent.UnsafeBuffer.boundsCheckWrap(UnsafeBuffer.java:1664)
2023-11-01 13:27:02     at org.agrona.core/org.agrona.concurrent.UnsafeBuffer.wrap(UnsafeBuffer.java:246)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.buffer.DefaultBufferPool.buffer(DefaultBufferPool.java:136)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientProduceFactory$KafkaProduceStream$KafkaProduceClient.doEncodeRecordInit(KafkaClientProduceFactory.java:1655)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientProduceFactory.flushRecordInit(KafkaClientProduceFactory.java:550)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientProduceFactory$KafkaProduceStream$KafkaProduceClient.flush(KafkaClientProduceFactory.java:1585)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientProduceFactory$KafkaProduceStream.onApplicationData(KafkaClientProduceFactory.java:981)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientProduceFactory$KafkaProduceStream.onApplication(KafkaClientProduceFactory.java:904)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.binding.kafka/io.aklivity.zilla.runtime.binding.kafka.internal.stream.KafkaClientProduceFactory.lambda$newStream$1(KafkaClientProduceFactory.java:257)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.handleReadInitial(DispatchAgent.java:1074)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.handleRead(DispatchAgent.java:1041)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.concurent.ManyToOneRingBuffer.read(ManyToOneRingBuffer.java:181)
2023-11-01 13:27:02     at io.aklivity.zilla.runtime.engine/io.aklivity.zilla.runtime.engine.internal.registry.DispatchAgent.doWork(DispatchAgent.java:701)
@akrambek akrambek added the bug Something isn't working label Nov 1, 2023
@akrambek akrambek changed the title [Kafka] Abrupt connection close causes kafka produce trigger an exception Gracefully handle out of slot exception in kafka cache client produce Nov 2, 2023
@akrambek akrambek mentioned this issue Nov 2, 2023
Merged
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
bug Something isn't working
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

Gracefully handle out of slot exception in kafka client produce
1 participant
@akrambek