[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16612374#comment-16612374 ]
Seweryn Habdank-Wojewodzki edited comment on KAFKA-7214 at 9/12/18 3:45 PM: ---------------------------------------------------------------------------- [~vvcephei] Back to the roots. What shall I say to Maintenance and Operations staff, when they need to handle the case below? {code} 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:200 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-51] State transition from PENDING_SHUTDOWN to DEAD 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:1128 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-51] Shutdown complete 2018-09-06 10:05:21 [ar313] [FATAL] SingleTopicstreamer:102 - Caught unhandled exception: Exception caught in process. taskId=0_2, processor=KSTREAM-SOURCE-0000000000, topic=ar313_medium_topic, partition=2, offset=1892533025; [org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:240), org.apache.kafka.streams.processor.internals.AssignedStreamsTasks.process(AssignedStreamsTasks.java:94), org.apache.kafka.streams.processor.internals.TaskManager.process(TaskManager.java:411), org.apache.kafka.streams.processor.internals.StreamThread.processAndMaybeCommit(StreamThread.java:922), org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:802), org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:749), org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:719)] in thread streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-51 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:200 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-58] State transition from PENDING_SHUTDOWN to DEAD 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:1128 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-58] Shutdown complete 2018-09-06 10:05:21 [ar313] [INFO ] KafkaStreams:261 - stream-client [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e] State transition from RUNNING to PENDING_SHUTDOWN {code} * What is wrong there? * What are the steps to avoid this in the future? * How to repair the situation? was (Author: habdank): [~vvcephei] Back to the roots. What shall I say to Maintenance and Operations staff, when they need to handle the case below? {code} 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:200 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-51] State transition from PENDING_SHUTDOWN to DEAD 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:1128 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-51] Shutdown complete 2018-09-06 10:05:21 [ar313] [FATAL] SingleTopicstreamer:102 - Caught unhandled exception: Exception caught in process. taskId=0_2, processor=KSTREAM-SOURCE-0000000000, topic=ar313_medium_topic, partition=2, offset=1892533025; [org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:240), org.apache.kafka.streams.processor.internals.AssignedStreamsTasks.process(AssignedStreamsTasks.java:94), org.apache.kafka.streams.processor.internals.TaskManager.process(TaskManager.java:411), org.apache.kafka.streams.processor.internals.StreamThread.processAndMaybeCommit(StreamThread.java:922), org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:802), org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:749), org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:719)] in thread streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-51 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:200 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-58] State transition from PENDING_SHUTDOWN to DEAD 2018-09-06 10:05:21 [ar313] [INFO ] StreamThread:1128 - stream-thread [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e-StreamThread-58] Shutdown complete 2018-09-06 10:05:21 [ar313] [INFO ] KafkaStreams:261 - stream-client [streamer-ar313-ar313_medium-15864802-2c1b-47e6-90f4-80b8b4fe4c3e] State transition from RUNNING to PENDING_SHUTDOWN {code} What is wrong there? What are the steps to avoid this in the future? How to repair the situation? > 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 > Reporter: Seweryn Habdank-Wojewodzki > Priority: Critical > > 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 (v7.6.3#76005)