aboutsummaryrefslogtreecommitdiff
path: root/examples/src/main/python/streaming/direct_kafka_wordcount.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/src/main/python/streaming/direct_kafka_wordcount.py')
-rw-r--r--examples/src/main/python/streaming/direct_kafka_wordcount.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/examples/src/main/python/streaming/direct_kafka_wordcount.py b/examples/src/main/python/streaming/direct_kafka_wordcount.py
index ea20678b9a..7097f7f450 100644
--- a/examples/src/main/python/streaming/direct_kafka_wordcount.py
+++ b/examples/src/main/python/streaming/direct_kafka_wordcount.py
@@ -28,6 +28,7 @@
examples/src/main/python/streaming/direct_kafka_wordcount.py \
localhost:9092 test`
"""
+from __future__ import print_function
import sys