Github user felixcheung commented on a diff in the pull request: https://github.com/apache/spark/pull/19535#discussion_r146024871 --- Diff: python/pyspark/streaming/kafka.py --- @@ -58,6 +60,7 @@ def createStream(ssc, zkQuorum, groupId, topics, kafkaParams=None, .. note:: Deprecated in 2.3.0 """ + warnings.warn("Deprecated in 2.3.0.", DeprecationWarning) --- End diff -- ditto here
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org