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: [email protected]
For additional commands, e-mail: [email protected]
