python-base--/tmp/kafka/KafkaPushTest.py

import json

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers=['10.3.150.162:9092'],
                         value_serializer=lambda v: json.dumps(v, ensure_ascii=False).encode('utf-8'),
                         max_request_size=20971520)


producer.send('accounting_statement_ocr', "123")

producer.flush()