def __init__(self, kafka_url,<EOL>zookeeper_url, zookeeper_path,<EOL>group, topic,<EOL>fetch_size=<NUM_LIT>,<EOL>repartition_callback=None,<EOL>commit_callback=None,<EOL>commit_timeout=<NUM_LIT:30>):
self._kazoo_client = None<EOL>self._set_partitioner = None<EOL>self._repartition_callback = repartition_callback<EOL>self._commit_callback = commit_callback<EOL>self._commit_timeout = commit_timeout<EOL>self._last_commit = <NUM_LIT:0><EOL>self._partitions = []<EOL>self._kafka_group = group<EOL>self._kafka_topic = topic<EOL>self._kafka_fetch_size = fetch_size<EOL>self._zookeeper_url = zookeeper_url<EOL>self._zookeeper_path = zookeeper_path<EOL>self._kafka = kafka_client.KafkaClient(kafka_url)<EOL>self._consumer = self._create_kafka_consumer()<EOL>
Init

             kafka_url            - Kafka location
             zookeeper_url        - Zookeeper location
             zookeeper_path       - Zookeeper path used for partition
                                    negotiation
             group                - Kafka consumer group
             topic                - Kafka topic
             repartition_callback - Callback to run when the Kafka consumer
                                    group changes.  Repartitioning takes a
                                    relatively long time so this is a good
                                    time to flush and commit any data.
             commit_callback      - Callback to run when the commit_timeout
                                    has elapsed between commits.
             commit_timeout       - Timeout between commits.