vamossagar12 commented on PR #13283:
URL: https://github.com/apache/kafka/pull/13283#issuecomment-1813728802
hey @ableegoldman , quick question. I am noticing that tests like
`shouldRecoverFromInvalidOffsetExceptionOnRestoreAndFinishRestore` are failing
with an error like
```
Exception in thread "clientId-StreamThread-1"
org.apache.kafka.streams.errors.StreamsException: java.lang.ClassCastException:
org.apache.kafka.streams.processor.internals.ReadOnlyTask cannot be cast to
org.apache.kafka.streams.processor.internals.StreamTask
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:715)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:633)
Caused by: java.lang.ClassCastException:
org.apache.kafka.streams.processor.internals.ReadOnlyTask cannot be cast to
org.apache.kafka.streams.processor.internals.StreamTask
at
org.apache.kafka.streams.processor.internals.TaskManager.getInputBufferSizeInBytes(TaskManager.java:1922)
at
org.apache.kafka.streams.processor.internals.StreamThread.runOnceWithoutProcessingThreads(StreamThread.java:880)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:674)
... 1 more
```
due to
https://github.com/apache/kafka/pull/13283/files#diff-8baa5d7209fc00074bf3fe24d709c2dcf2a44c1623d7ced8c0e29c1d832a3bcbR1919-R1926
I haven't followed the latest developments of streams but it appears to me
that a new type of task has been added called `ReadOnlyTask`. It had worked for
StandbyTask because that task is not active but wanted to understand, do we
need this pausing semantics for ReadOnlyTask as well?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
