#!/app/python/bin/python
from kafka import KafkaProducer
from kafka.errors import KafkaError
producer = KafkaProducer(bootstrap_servers=['node1.qrm:9092','node2.qrm:9092','node3.qrm:9092'])
producer.send('accesslog_wp-bigdata',str.encode('this is test'))
