Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- self._client = KafkaClient(metrics=self._metrics, **self.config),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
- self.config['api_version'] = self.check_version(timeout=check_timeout),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 819, in check_version,
- raise Errors.NoBrokersAvailable(),
- NoBrokersAvailable: NoBrokersAvailable,
- will create consumer ['kafka:9092'] history fce9239a-29e1-446d-b496-46048acf78a9,
- Process device-data-watcher:,
- Traceback (most recent call last):,
- File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
- self.run(),
- File "history/subscriber/kafkaSubscriber.py", line 254, in run,
- self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
- self._client = KafkaClient(metrics=self._metrics, **self.config),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
- self.config['api_version'] = self.check_version(timeout=check_timeout),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 819, in check_version,
- raise Errors.NoBrokersAvailable(),
- NoBrokersAvailable: NoBrokersAvailable,
- will create consumer ['kafka:9092'] history 8c27d0a2-af68-4781-ab52-8fb5d80637e6,
- Process dojot.device-manager.device-watcher:,
- Traceback (most recent call last):,
- File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
- self.run(),
- File "history/subscriber/kafkaSubscriber.py", line 254, in run,
- self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
- self._client = KafkaClient(metrics=self._metrics, **self.config),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
- self.config['api_version'] = self.check_version(timeout=check_timeout),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 819, in check_version,
- raise Errors.NoBrokersAvailable(),
- NoBrokersAvailable: NoBrokersAvailable,
- will create consumer ['kafka:9092'] history a1907dcf-1696-4e8e-aa55-84156164727d,
- Process device-data-watcher:,
- Traceback (most recent call last):,
- File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
- self.run(),
- File "history/subscriber/kafkaSubscriber.py", line 254, in run,
- self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
- self._client = KafkaClient(metrics=self._metrics, **self.config),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
- self.config['api_version'] = self.check_version(timeout=check_timeout),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 819, in check_version,
- raise Errors.NoBrokersAvailable(),
- NoBrokersAvailable: NoBrokersAvailable,
- will create consumer ['kafka:9092'] history 179d54be-18dc-4f4d-ad65-88038f3f2264,
- Process dojot.device-manager.device-watcher:,
- Traceback (most recent call last):,
- File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
- self.run(),
- File "history/subscriber/kafkaSubscriber.py", line 254, in run,
- self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
- self._client = KafkaClient(metrics=self._metrics, **self.config),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
- self.config['api_version'] = self.check_version(timeout=check_timeout),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 819, in check_version,
- raise Errors.NoBrokersAvailable(),
- NoBrokersAvailable: NoBrokersAvailable,
- will create consumer ['kafka:9092'] history ad9f10d8-50b7-4a91-bd57-62c7c0c9d983,
- Process device-data-watcher:,
- Traceback (most recent call last):,
- File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
- self.run(),
- File "history/subscriber/kafkaSubscriber.py", line 254, in run,
- self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
- self._client = KafkaClient(metrics=self._metrics, **self.config),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
- self.config['api_version'] = self.check_version(timeout=check_timeout),
- File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 819, in check_version,
- raise Errors.NoBrokersAvailable(),
- NoBrokersAvailable: NoBrokersAvailable,
- will create consumer ['kafka:9092'] history a774dc07-f4b1-4f76-b1c2-371362160bab,
- will create consumer ['kafka:9092'] history ae3b23fa-e8d4-4da1-a713-9e77919c8a76,
- will create consumer ['kafka:9092'] history 0001d778-9b68-4a68-8526-c2baefcbf45b,
- will create consumer ['kafka:9092'] history b7e91988-8ccd-4021-9058-a42059b4eeaa,
- will create consumer ['kafka:9092'] history fce9239a-29e1-446d-b496-46048acf78a9,
- will create consumer ['kafka:9092'] history 8c27d0a2-af68-4781-ab52-8fb5d80637e6,
- will create consumer ['kafka:9092'] history a1907dcf-1696-4e8e-aa55-84156164727d,
- will create consumer ['kafka:9092'] history 179d54be-18dc-4f4d-ad65-88038f3f2264,
- will create consumer ['kafka:9092'] history ad9f10d8-50b7-4a91-bd57-62c7c0c9d983,
- kafka consumer created 8c27d0a2-af68-4781-ab52-8fb5d80637e6 - 10.7286741734,
- kafka consumer created a1907dcf-1696-4e8e-aa55-84156164727d - 14.5745501518,
- kafka consumer created 0001d778-9b68-4a68-8526-c2baefcbf45b - 16.4417479038,
- kafka consumer created a774dc07-f4b1-4f76-b1c2-371362160bab - 16.9095199108,
- kafka consumer created 179d54be-18dc-4f4d-ad65-88038f3f2264 - 14.5493547916,
- kafka consumer created b7e91988-8ccd-4021-9058-a42059b4eeaa - 16.4171760082,
- kafka consumer created fce9239a-29e1-446d-b496-46048acf78a9 - 16.3999609947,
- kafka consumer created ae3b23fa-e8d4-4da1-a713-9e77919c8a76 - 16.4956378937,
- kafka consumer created ad9f10d8-50b7-4a91-bd57-62c7c0c9d983 - 14.5293591022,
- Data handler raised an unknown exception. Ignoring. ,
- 'id',
- Data handler raised an unknown exception. Ignoring. ,
- 'id',
- Data handler raised an unknown exception. Ignoring. ,
- 'id',
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement