Kafka send问题

from kafka import KafkaProducer

import pickle


producer = KafkaProducer(
    bootstrap_servers=‘10.2.2.139:9092‘,
    key_serializer=lambda k:pickle.dumps(k),
    value_serializer=lambda v:pickle.dumps(v))

producer.send(‘20190428‘,key=‘name‘,value=‘cys‘,partition=0)
# for i in range(10):
#     for ii in range(1):
#         result = producer.send(‘20190428-4‘,"chenyishi".encode())
#         print(result)
#         print(type(result))

# producer.flush()
producer.close()  # 不加有可能导致内存泄漏