ubuntu用命令行导入了python-kafka库
时间: 2023-12-18 07:02:05 浏览: 111
linux服务下,kafka服务搭建使用
好的,那么您已经成功地安装了Python的kafka库。接下来您可以在Python脚本中导入该库并使用它来连接和操作Kafka集群。例如:
```python
from kafka import KafkaProducer
from kafka import KafkaConsumer
# 连接Kafka集群并创建Producer和Consumer
producer = KafkaProducer(bootstrap_servers='localhost:9092')
consumer = KafkaConsumer('my_topic', bootstrap_servers='localhost:9092')
# 向Kafka发送消息
producer.send('my_topic', b'Hello, Kafka!')
# 从Kafka消费消息
for message in consumer:
print(message.value)
```
阅读全文