# -*- coding: utf-8 -*-
# !/usr/bin/env python
import logging
import os
import time

from kafka import KafkaConsumer

from base import init_env

logger = logging.getLogger("kafkaConsumer")

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "configs.testing")

init_env(interactive = False)

consumer = KafkaConsumer('devicelog',
                         bootstrap_servers=['211.159.224.10:9081','211.159.224.10:9082','211.159.224.10:9083'])
count = 0

# while True:
#     message = consumer.poll(timeout_ms = 5000)
#
#     if message:
#         logger.error(message)
#         count = count + 1
#
#         logger.error("received {}".format(count))

for message in consumer:
    logger.error(message)
    count = count + 1
    logger.error("received {}".format(count))