Confluent_kafka module

Confluent Cloud
1

I am trying to start a project using kafka python client with a file pulse connector.
‘’’
import sys
import confluent_kafka
from confluent_kafka import Consumer, Producer, KafkaError
‘’’
yields error:
Traceback (most recent call last):
File “c:\Users\Trading\Desktop\conn\confluent_stream.py”, line 3, in
from confluent_kafka import Consumer, Producer, KafkaError
ImportError: cannot import name ‘Consumer’ from ‘confluent_kafka’ (unknown location)

i installed, uninstalled, i checked paths…PS C:\Users\Trading\Desktop\conn> pip show confluent_kafka
Name: confluent-kafka
Version: 2.0.2
Summary: Confluent’s Python client for Apache Kafka
Home-page: GitHub - confluentinc/confluent-kafka-python: Confluent's Kafka Python Client
Author: Confluent Inc
Author-email: support@confluent.io
License:
Location: c:\users\trading\appdata\local\packages\pythonsoftwarefoundation.python.3.10_qbz5n2kfra8p0\localcache\local-packages\python310\site-packages
Requires:
Required-by:/…
I am not sure why my scrip[t cant recognize the modules for Consumer, Producer, and KafkaError.

Appreciate any help

2

C:\Users\Trading>python
Python 3.10.10 (tags/v3.10.10:aad5f6a, Feb 7 2023, 17:20:36) [MSC v.1929 64 bit (AMD64)] on win32
Type “help”, “copyright”, “credits” or “license” for more information.

import confluent_kafka
print(dir(confluent_kafka))
[‘Consumer’, ‘ConsumerGroupState’, ‘ConsumerGroupTopicPartitions’, ‘DeserializingConsumer’, ‘KafkaError’, ‘KafkaException’, ‘Message’, ‘Node’, ‘OFFSET_BEGINNING’, ‘OFFSET_END’, ‘OFFSET_INVALID’, ‘OFFSET_STORED’, ‘Producer’, ‘SerializingProducer’, ‘TIMESTAMP_CREATE_TIME’, ‘TIMESTAMP_LOG_APPEND_TIME’, ‘TIMESTAMP_NOT_AVAILABLE’, ‘ThrottleEvent’, ‘TopicPartition’, ‘all’, ‘builtins’, ‘cached’, ‘doc’, ‘file’, ‘loader’, ‘name’, ‘package’, ‘path’, ‘spec’, ‘version’, ‘_model’, ‘_resolve_plugins’, ‘cimpl’, ‘deserializing_consumer’, ‘error’, ‘libversion’, ‘serialization’, ‘serializing_producer’, ‘version’]