from kafka import KafkaClientfrom kafka.producer import SimpleProducer

def send_data_2_kafka(datas):  '''    向kafka解析隊(duì)列發(fā)送數(shù)據(jù)  '''  client = KafkaClient(hosts=KAFKABROKER.split(","), timeout=30)  producer = SimpleProducer(client, async=False)   curcount = len(datas)/PARTNUM  for i in range(0, PARTNUM):    start = i*curcount    if i != PARTNUM - 1:      end = (i+1)*curcount      curdata = datas[start:end]      producer.send_messages(TOPICNAME, *curdata)    else:      curdata = datas[start:]      producer.send_messages(TOPICNAME, *curdata)      producer.stop()  client.close()