Seweryn Habdank-Wojewodzki created KAFKA-7214:
-------------------------------------------------

             Summary: 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
            Reporter: Seweryn Habdank-Wojewodzki


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)

Reply via email to