Совместимость с искрой Кафки

#apache-spark #apache-kafka

#apache-искра #апач-кафка

Вопрос:

Этот код выдает ошибку «нет модуля с именем Кафка».

 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, которые предотвращают эту ошибку ?