tencent cloud

import uuid
from kafka import KafkaConsumer,TopicPartition,OffsetAndMetadata
consumer = KafkaConsumer(
//您的主题名称，将上图中的主题名称填写到此处      
'in-633a268c-XXXX-4a4c-XXXX-7a9a1a7baXXXX',  
group_id = uuid.uuid4().hex,
auto_offset_reset='earliest',
//kafka服务地址，将上图中的接入点信息填写到此处   
bootstrap_servers = ['ckafka-lweXXXXk.ap-
guangzhou.ckafka.tencentcloudmq.com:6012'],
security_protocol = "SASL_PLAINTEXT",
sasl_mechanism = 'PLAIN',   
//SASL信息，将kafka实例信息和用户名用#拼接填入此处，实例信息在接入点信息中   
sasl_plain_username = "ckafka-lweXXXXk#cls-2pGgXXX",
//SASL信息，将上图中的密码填入此处   
sasl_plain_password = "8uleOOPXXX",
api_version = (0,10,0)
)
print('begin')
for message in consumer:
    print('begins')
    print ("Topic:[%s] Partition:[%d] Offset:[%d] Value:[%s]" % (message.topic, message.partition, message.offset, message.value))
    print('end')