cannot import name 'IncompatibleBrokerVersion' from 'kafka.errors'

[LeGi0N09]

ImportError Traceback (most recent call last) in <cell line: 1>() ----> 1 from kafka import KafkaProducer 2 import json 3 import pandas as pd 4 import time 5

2 frames /usr/local/lib/python3.10/dist-packages/kafka/admin/client.py in 14 from kafka.coordinator.protocol import ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment, ConsumerProtocol 15 import kafka.errors as Errors ---> 16 from kafka.errors import ( 17 IncompatibleBrokerVersion, KafkaConfigurationError, NotControllerError, 18 UnrecognizedBrokerVersion, IllegalArgumentError)

ImportError: cannot import name 'IncompatibleBrokerVersion' from 'kafka.errors' (/usr/local/lib/python3.10/dist-packages/kafka/errors.py)