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)