Advertisement
Guest User

Untitled

a guest
Jun 27th, 2019
60
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 7.09 KB | None | 0 0
  1. self._client = KafkaClient(metrics=self._metrics, **self.config),
  2. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
  3. self.config['api_version'] = self.check_version(timeout=check_timeout),
  4. 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,
  5. raise Errors.NoBrokersAvailable(),
  6. NoBrokersAvailable: NoBrokersAvailable,
  7. will create consumer ['kafka:9092'] history fce9239a-29e1-446d-b496-46048acf78a9,
  8. Process device-data-watcher:,
  9. Traceback (most recent call last):,
  10. File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
  11. self.run(),
  12. File "history/subscriber/kafkaSubscriber.py", line 254, in run,
  13. self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
  14. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
  15. self._client = KafkaClient(metrics=self._metrics, **self.config),
  16. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
  17. self.config['api_version'] = self.check_version(timeout=check_timeout),
  18. 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,
  19. raise Errors.NoBrokersAvailable(),
  20. NoBrokersAvailable: NoBrokersAvailable,
  21. will create consumer ['kafka:9092'] history 8c27d0a2-af68-4781-ab52-8fb5d80637e6,
  22. Process dojot.device-manager.device-watcher:,
  23. Traceback (most recent call last):,
  24. File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
  25. self.run(),
  26. File "history/subscriber/kafkaSubscriber.py", line 254, in run,
  27. self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
  28. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
  29. self._client = KafkaClient(metrics=self._metrics, **self.config),
  30. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
  31. self.config['api_version'] = self.check_version(timeout=check_timeout),
  32. 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,
  33. raise Errors.NoBrokersAvailable(),
  34. NoBrokersAvailable: NoBrokersAvailable,
  35. will create consumer ['kafka:9092'] history a1907dcf-1696-4e8e-aa55-84156164727d,
  36. Process device-data-watcher:,
  37. Traceback (most recent call last):,
  38. File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
  39. self.run(),
  40. File "history/subscriber/kafkaSubscriber.py", line 254, in run,
  41. self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
  42. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
  43. self._client = KafkaClient(metrics=self._metrics, **self.config),
  44. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
  45. self.config['api_version'] = self.check_version(timeout=check_timeout),
  46. 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,
  47. raise Errors.NoBrokersAvailable(),
  48. NoBrokersAvailable: NoBrokersAvailable,
  49. will create consumer ['kafka:9092'] history 179d54be-18dc-4f4d-ad65-88038f3f2264,
  50. Process dojot.device-manager.device-watcher:,
  51. Traceback (most recent call last):,
  52. File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
  53. self.run(),
  54. File "history/subscriber/kafkaSubscriber.py", line 254, in run,
  55. self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
  56. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
  57. self._client = KafkaClient(metrics=self._metrics, **self.config),
  58. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
  59. self.config['api_version'] = self.check_version(timeout=check_timeout),
  60. 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,
  61. raise Errors.NoBrokersAvailable(),
  62. NoBrokersAvailable: NoBrokersAvailable,
  63. will create consumer ['kafka:9092'] history ad9f10d8-50b7-4a91-bd57-62c7c0c9d983,
  64. Process device-data-watcher:,
  65. Traceback (most recent call last):,
  66. File "/usr/local/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap,
  67. self.run(),
  68. File "history/subscriber/kafkaSubscriber.py", line 254, in run,
  69. self.consumer = KafkaConsumer(bootstrap_servers=self.broker, group_id=self.group_id),
  70. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/consumer/group.py", line 340, in __init__,
  71. self._client = KafkaClient(metrics=self._metrics, **self.config),
  72. File "/usr/local/lib/python2.7/site-packages/kafka_python-1.4.3-py2.7.egg/kafka/client_async.py", line 219, in __init__,
  73. self.config['api_version'] = self.check_version(timeout=check_timeout),
  74. 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,
  75. raise Errors.NoBrokersAvailable(),
  76. NoBrokersAvailable: NoBrokersAvailable,
  77. will create consumer ['kafka:9092'] history a774dc07-f4b1-4f76-b1c2-371362160bab,
  78. will create consumer ['kafka:9092'] history ae3b23fa-e8d4-4da1-a713-9e77919c8a76,
  79. will create consumer ['kafka:9092'] history 0001d778-9b68-4a68-8526-c2baefcbf45b,
  80. will create consumer ['kafka:9092'] history b7e91988-8ccd-4021-9058-a42059b4eeaa,
  81. will create consumer ['kafka:9092'] history fce9239a-29e1-446d-b496-46048acf78a9,
  82. will create consumer ['kafka:9092'] history 8c27d0a2-af68-4781-ab52-8fb5d80637e6,
  83. will create consumer ['kafka:9092'] history a1907dcf-1696-4e8e-aa55-84156164727d,
  84. will create consumer ['kafka:9092'] history 179d54be-18dc-4f4d-ad65-88038f3f2264,
  85. will create consumer ['kafka:9092'] history ad9f10d8-50b7-4a91-bd57-62c7c0c9d983,
  86. kafka consumer created 8c27d0a2-af68-4781-ab52-8fb5d80637e6 - 10.7286741734,
  87. kafka consumer created a1907dcf-1696-4e8e-aa55-84156164727d - 14.5745501518,
  88. kafka consumer created 0001d778-9b68-4a68-8526-c2baefcbf45b - 16.4417479038,
  89. kafka consumer created a774dc07-f4b1-4f76-b1c2-371362160bab - 16.9095199108,
  90. kafka consumer created 179d54be-18dc-4f4d-ad65-88038f3f2264 - 14.5493547916,
  91. kafka consumer created b7e91988-8ccd-4021-9058-a42059b4eeaa - 16.4171760082,
  92. kafka consumer created fce9239a-29e1-446d-b496-46048acf78a9 - 16.3999609947,
  93. kafka consumer created ae3b23fa-e8d4-4da1-a713-9e77919c8a76 - 16.4956378937,
  94. kafka consumer created ad9f10d8-50b7-4a91-bd57-62c7c0c9d983 - 14.5293591022,
  95. Data handler raised an unknown exception. Ignoring. ,
  96. 'id',
  97. Data handler raised an unknown exception. Ignoring. ,
  98. 'id',
  99. Data handler raised an unknown exception. Ignoring. ,
  100. 'id',
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement