卡夫卡火花兼容性

Question

这些代码给出了错误“没有名为 Kafka 的模块”

import os
from datetime import datetime
import time
import threading
import json
from kafka import KafkaProducer
from kafka.errors import KafkaError
import pandas as pd
from sklearn.model_selection import train_test_split

有哪些兼容版本的 K=kafka、oython 和 spark 可以防止此错误？

Answer 1

您在这里没有使用任何 Spark 库。

看来你需要安装 kafka-python