写一个pyhon消费卡夫卡的程序
时间: 2023-10-02 10:11:10 浏览: 147
python 实现购物程序
好的,以下是一个简单的 Python 消费 Kafka 的程序示例:
```python
from kafka import KafkaConsumer
# 创建Kafka消费者
consumer = KafkaConsumer('test-topic', bootstrap_servers=['localhost:9092'])
# 从Kafka消费者接收消息
for msg in consumer:
print(msg)
```
这个程序将连接到本地 Kafka 服务器并订阅名为 `test-topic` 的主题。然后,它将一直监听该主题并打印接收到的消息。
当然,在实际生产环境中,您可能需要更复杂的逻辑来处理消息,例如将它们写入数据库或发送到其他系统。但是这个简单的示例可以帮助您快速入门。
阅读全文