【kafka】基于python发送kafka消息

一、场景

　　测试过程中，需要对kafka发送消息，以模拟相关业务场景

 

二、环境

pip install kafka-python  

 

三、脚本

import json
import time
import uuid
import datetime
import requests
from kafka import KafkaProducerKAFKA_BOOTSTRAP_SERVERS = ["192.168.1.100:9093"]def send_user_info(i):json_data = {"username": "tester",......}print(json_data)data = {"MSG_ID": str(uuid.uuid4()),"MSG_BODY": json_data,}topic = "ods_blctms_qx_gps_vehicleinfo"producer = KafkaProducer(bootstrap_servers=KAFKA_BOOTSTRAP_SERVERS)data_json = json.dumps(data).encode('utf-8')future = producer.send(topic, data_json)print(future.get())time.sleep(1.0)if __name__ == "__main__":i = 0while True:i += 1send_user_info(i%50)