本文介绍如何在VPC环境下使用Python SDK接入消息队列Kafka版的默认接入点并收发消息。
安装Python依赖库
执行以下命令安装Python依赖库。
pip install kafka-python
准备配置
创建消息队列Kafka版配置文件setting.py。
kafka_setting = {
'bootstrap_servers': ["XXX", "XXX", "XXX"],
'topic_name': 'XXX',
'consumer_id': 'XXX'
}
参数 | 描述 |
---|---|
bootstrap_servers | 默认接入点。您可在消息队列Kafka版控制台的实例详情页面的基本信息区域获取。 |
topic_name | Topic名称。您可在消息队列Kafka版控制台的Topic管理页面获取。 |
consumer_id | Consumer Group名称。您可在消息队列Kafka版控制台的Consumer Group管理页面获取。 |