Sending data to kafka

sendpykafka.py

from pykafka import KafkaClient

path="/path/of/log/file.log"
host="ip.ad.dr.ess" 
port=9092
topic="name-of-the-topic"

client = KafkaClient(host:port)
topic = client.topics[topic]
producer = topic.get_producer(sync=True,delivery_reports=True)

def sendkafka(msg):
    producer.produce(msg.encode())

with open(path) as f:
    for line in f:
        sendkafka(line)