Extension:EventLogging/Python

Skeleton Python kafka client for stat1007

#!/usr/bin/env python
# -*- coding: utf-8 -*-
from pykafka import KafkaClient

client = KafkaClient(hosts='kafka1012.eqiad.wmnet:9092')
topic = client.topics['eventlogging_Edit']
consumer = topic.get_simple_consumer()

for message in consumer:
        print message.value         # or whatever