| 123456789101112131415161718192021222324252627282930313233343536 |
- # -*- 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))
|
