为什么是kafkaUtils.createStream文件（）向我抛出错误？

Question

我是pyspark的新手，我正在尝试将Spark与ApacheKafka联系起来。我使用下面提到的代码连接，但我得到的错误。我请求别人告诉我我做错了什么。你知道吗

import sys
from pyspark import SparkContext, SparkConf
from pyspark.streaming import StreamingContext
from pyspark.streaming.kafka import KafkaUtils
from uuid import uuid1

if __name__ == "__main__":
    sc = SparkContext(appName="PythonStreaming")
    ssc = StreamingContext(sc, 2) # 2 second window
    kvs = KafkaUtils.createStream(ssc, \
                                  "localhost:9092", \
                                  "test",\
                                  {test:1})
    ssc.start()
    ssc.awaitTermination()

我得到这个错误

NameError: name 'test' is not defined

而test确实是我的主题名。你知道吗

Answer 1

只需使用以下命令显示主题列表，并确保该主题可用。你知道吗

bin/kafka-topics.sh  list  zookeeper localhost:2181