René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Beaver to kafka","articleBody":"Nothing is being written to kafka queue (it is being auto created). After some line appearing in log there is NoneType error from beaver daemon\r\n\r\npython-2.7.12-2\r\n\u003e\u003e\u003e print kafka.__version__\r\n1.3.5\r\n\r\n[beaver]\r\nlogstash_version: 1\r\ntransport: kafka\r\nkafka_client_id: beaver-kafka-1\r\nkafka_hosts: 10.151.23.10:9092,10.151.23.11:9092,10.151.23.12:9092\r\nkafka_key: beaverrrr\r\nkafka_topic: beaverrrr\r\nkafka_batch_n: 10\r\nkafka_batch_t: 10\r\n\r\n[/app/my.log]\r\n\r\ntype: syslog\r\ntags: nta02\r\n\r\nkafka\r\n0.11.0.1\r\n\r\n\u003e [2018-01-31 15:00:10,281] INFO    Starting worker...\r\n\u003e [2018-01-31 15:00:10,292] INFO    Starting queue consumer\r\n\u003e [2018-01-31 15:00:10,297] INFO    Working...\r\n\u003e [2018-01-31 15:00:10,342] INFO    [/app/my.log] - watching logfile\r\n\u003e [2018-01-31 15:00:24,791] ERROR   Exception caught sending message/s : 'NoneType' object is not callable\r\n\u003e [2018-01-31 15:00:24,792] INFO    Caught transport exception: Unspecified exception encountered\r\n\u003e [2018-01-31 15:00:24,792] INFO    Reconnecting in 3 seconds\r\n\u003e [2018-01-31 15:00:27,851] ERROR   Exception caught sending message/s : 'NoneType' object is not callable\r\n\u003e [2018-01-31 15:00:27,851] INFO    Caught transport exception: Unspecified exception encountered\r\n\u003e [2018-01-31 15:00:27,851] INFO    Reconnecting in 9 seconds\r\n\u003e [2018-01-31 15:00:36,388] INFO    SIGINT detected\r\n\u003e [2018-01-31 15:00:36,389] INFO    Shutting down. Please wait...\r\n\u003e [2018-01-31 15:00:36,440] INFO    SIGINT detected\r\n\u003e [2018-01-31 15:00:36,441] INFO    Shutting down. Please wait...\r\n\u003e Process Process-1:\r\n\u003e Traceback (most recent call last):\r\n\u003e   File \"/opt/freeware/lib/python2.7/multiprocessing/process.py\", line 258, in _bootstrap\r\n\u003e     self.run()\r\n\u003e   File \"/opt/freeware/lib/python2.7/multiprocessing/process.py\", line 114, in run\r\n\u003e     self._target(*self._args, **self._kwargs)\r\n\u003e   File \"/opt/freeware/lib/python2.7/site-packages/beaver/dispatcher/tail.py\", line 83, in create_queue_producer\r\n\u003e     manager.run()\r\n\u003e   File \"/opt/freeware/lib/python2.7/site-packages/beaver/worker/tail_manager.py\", line 83, in run\r\n\u003e     time.sleep(interval)\r\n\u003e   File \"/opt/freeware/lib/python2.7/site-packages/beaver/dispatcher/tail.py\", line 51, in cleanup\r\n\u003e     manager_proc.terminate()\r\n\u003e   File \"/opt/freeware/lib/python2.7/multiprocessing/process.py\", line 137, in terminate\r\n\u003e     self._popen.terminate()\r\n\u003e AttributeError: 'NoneType' object has no attribute 'terminate'\r\n\u003e [2018-01-31 15:00:36,447] INFO    Shutdown complete.\r\n\u003e ","author":{"url":"https://github.com/madiTG","@type":"Person","name":"madiTG"},"datePublished":"2018-01-31T14:04:45.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/424/python-beaver/issues/424"}