void setPartitionAssignedTime(final long lastPartitionAssignedMs) {
        this.lastPartitionAssignedMs = lastPartitionAssignedMs;
    }
@return The state this instance is in
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java