tencent cloud

 producer = KafkaProducer(
         bootstrap_servers = ['xx.xx.xx.xx:port'],$address
         api_version = (1, 1),
         security_protocol = "SASL_PLAINTEXT",
         sasl_mechanism = "PLAIN",
         sasl_plain_username = "username",# username
         sasl_plain_password = "password",# password
 )

 message = "Hello World! Hello Ckafka!"
 msg = json.dumps(message).encode()
 producer.send('topic_name', value = msg)#Topic name
 print("produce message " + message + " success.")
 producer.close()

   consumer = KafkaConsumer(
       'topic_name',#topic name
       group_id = "group_id",#Consumption group
       bootstrap_servers = ['xx.xx.xx.xx:port'],# address
       api_version = (1,1),

       security_protocol = "SASL_PLAINTEXT",
       sasl_mechanism = 'PLAIN',
       sasl_plain_username = "username",# username
       sasl_plain_password = "password",# password
   )

   for message in consumer:
       print ("Topic:[%s] Partition:[%d] Offset:[%d] Value:[%s]" %
       (message.topic, message.partition, message.offset, message.value))