 <p>You're using Spark 1.3.0 and Python version of <code>createDirectStream</code> has been introduced in Spark 1.4.0. Spark 1.3 provides only Scala and Java implementations.</p> <p>If you want to use direct stream you'll have to update your Spark installation. </p>