org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:400) ~[kafka-streams-:475) ~[kafka-streams-2.5.1.jar:na]
at org.apache.kafka.streams.processor.internals.TaskManager.process(StreamThread.java:6
at org.apache.kafka.streams.state.internals.NamedCache.flush(NamedCache.java:151) ~[kafka-streams-2.4.0~[kafka-streams-2.4.0.jar:?]~[kafka-streams-2.4.0.jar:?]at org.apache.kafka.streams.processor.internals.Str
(RocksDBTimestampedStore.java:87) at org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:54)
at org.apache.kafka.streams</e
(StreamThread.java:942) at org.apache.kafka.streams.processor.internalsorg.apache.kafka.streams.processor.internals.StreamThread.runLoop:67) at org.apache.kafka.streams.state.internals.ChangeLoggingWindowBytesStore.在org.apache.kafka.