[KAFKA-4563] State transitions error PARTITIONS_REVOKED to NOT_RUNNING

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.10.2.0
• Component/s: streams
• Assignee: Eno Thereska
• Reporter: Eno Thereska
• Created: 20/Dec/16 18:15
• Updated: 11/Oct/17 00:11
• Resolved: 26/Jun/17 10:50

Description

When starting and stopping streams quickly, the following exception is thrown:

java.lang.IllegalStateException: Incorrect state transition from PARTITIONS_REVOKED to NOT_RUNNING
at org.apache.kafka.streams.processor.internals.StreamThread.setState(StreamThread.java:164)
at org.apache.kafka.streams.processor.internals.StreamThread.shutdown(StreamThread.java:414)
at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:366)

A temporary fix is to convert the exception into a warning, since clearly not all state transitions are thought through yet.