You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Seweryn Habdank-Wojewodzki (Jira)" <ji...@apache.org> on 2021/10/06 07:37:00 UTC
[jira] [Resolved] (KAFKA-7214) Mystic FATAL error
[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Seweryn Habdank-Wojewodzki resolved KAFKA-7214.
-----------------------------------------------
Resolution: Workaround
The solution is to avoid low values of {{max.block.ms}}
> Mystic FATAL error
> ------------------
>
> Key: KAFKA-7214
> URL: https://issues.apache.org/jira/browse/KAFKA-7214
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 0.11.0.3, 1.1.1, 2.3.0, 2.2.1
> Reporter: Seweryn Habdank-Wojewodzki
> Priority: Critical
> Attachments: qns-1.1.zip, qns-1.zip
>
>
> Dears,
> Very often at startup of the streaming application I got exception:
> {code}
> Exception caught in process. taskId=0_1, processor=KSTREAM-SOURCE-0000000000, topic=my_instance_medium_topic, partition=1, offset=198900203; [org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:212), org.apache.kafka.streams.processor.internals.AssignedTasks$2.apply(AssignedTasks.java:347), org.apache.kafka.streams.processor.internals.AssignedTasks.applyToRunningTasks(AssignedTasks.java:420), org.apache.kafka.streams.processor.internals.AssignedTasks.process(AssignedTasks.java:339), org.apache.kafka.streams.processor.internals.StreamThread.processAndPunctuate(StreamThread.java:648), org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:513), org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:482), org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:459)] in thread my_application-my_instance-my_instance_medium-72ee1819-edeb-4d85-9d65-f67f7c321618-StreamThread-62
> {code}
> and then (without shutdown request from my side):
> {code}
> 2018-07-30 07:45:02 [ar313] [INFO ] StreamThread:912 - stream-thread [my_application-my_instance-my_instance-72ee1819-edeb-4d85-9d65-f67f7c321618-StreamThread-62] State transition from PENDING_SHUTDOWN to DEAD.
> {code}
> What is this?
> How to correctly handle it?
> Thanks in advance for help.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)