2025-04-04 19:37:03,281 - INFO - parkwatch Program started
2025-04-04 19:37:03,284 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 19:37:03,287 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:37:03,288 - INFO - Waiting 16426.711119 seconds until the next cleanup task.
2025-04-04 19:37:03,289 - INFO - Probing node bootstrap-0 broker version
2025-04-04 19:37:03,294 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:37:03,295 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 19:37:03,296 - INFO - start process : top -H
2025-04-04 19:37:03,405 - INFO - Broker version identified as 2.5.0
2025-04-04 19:37:03,405 - INFO - Set configuration api_version=(2, 5, 0) to skip auto check_version requests on startup
2025-04-04 19:37:03,406 - WARNING - group_id is None: disabling auto-commit.
2025-04-04 19:37:03,406 - INFO - Updating subscribed topics to: ('cameralist',)
2025-04-04 19:37:03,406 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 19:37:03,412 - INFO - Updated partition assignment: [TopicPartition(topic='cameralist', partition=0)]
2025-04-04 19:37:03,413 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:37:03,513 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:37:03,513 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. 
2025-04-04 19:39:57,210 - INFO - parkwatch Program started
2025-04-04 19:39:57,214 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 19:39:57,217 - INFO - Waiting 16252.78264 seconds until the next cleanup task.
2025-04-04 19:39:57,218 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:39:57,218 - INFO - Probing node bootstrap-0 broker version
2025-04-04 19:39:57,223 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:39:57,225 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 19:39:57,225 - INFO - stop success {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} (PID: 38855)
2025-04-04 19:39:57,226 - INFO - start process : top -H
2025-04-04 19:39:57,333 - INFO - Broker version identified as 2.5.0
2025-04-04 19:39:57,333 - INFO - Set configuration api_version=(2, 5, 0) to skip auto check_version requests on startup
2025-04-04 19:39:57,333 - WARNING - group_id is None: disabling auto-commit.
2025-04-04 19:39:57,333 - INFO - Updating subscribed topics to: ('cameralist',)
2025-04-04 19:39:57,333 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 19:39:57,340 - INFO - Updated partition assignment: [TopicPartition(topic='cameralist', partition=0)]
2025-04-04 19:39:57,340 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:39:57,440 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:39:57,441 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. 
2025-04-04 19:40:09,015 - INFO - Exiting program, stopping all processes...
2025-04-04 19:40:09,034 - ERROR - Error stopping process top (PID: 37032): [Errno 1] Operation not permitted
2025-04-04 19:40:09,034 - INFO - Sent SIGTERM to process: top (PID: 39022)
2025-04-04 19:40:15,909 - INFO - parkwatch Program started
2025-04-04 19:40:15,913 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 19:40:15,917 - INFO - Waiting 16234.082476 seconds until the next cleanup task.
2025-04-04 19:40:15,919 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:40:15,919 - INFO - Probing node bootstrap-0 broker version
2025-04-04 19:40:15,924 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:40:15,926 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 19:40:15,926 - INFO - start process : top -H
2025-04-04 19:40:16,031 - INFO - Broker version identified as 2.5.0
2025-04-04 19:40:16,031 - INFO - Set configuration api_version=(2, 5, 0) to skip auto check_version requests on startup
2025-04-04 19:40:16,032 - WARNING - group_id is None: disabling auto-commit.
2025-04-04 19:40:16,032 - INFO - Updating subscribed topics to: ('cameralist',)
2025-04-04 19:40:16,032 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 19:40:16,037 - INFO - Updated partition assignment: [TopicPartition(topic='cameralist', partition=0)]
2025-04-04 19:40:16,038 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:40:16,138 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:40:16,138 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. 
2025-04-04 19:40:19,749 - INFO - Exiting program, stopping all processes...
2025-04-04 19:40:19,766 - ERROR - Error stopping process top (PID: 37032): [Errno 1] Operation not permitted
2025-04-04 19:40:19,766 - INFO - Sent SIGTERM to process: top (PID: 39066)
2025-04-04 19:43:26,009 - INFO - parkwatch Program started
2025-04-04 19:43:26,012 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 19:43:26,017 - INFO - Waiting 16043.982873 seconds until the next cleanup task.
2025-04-04 19:43:26,017 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:43:26,017 - INFO - Probing node bootstrap-0 broker version
2025-04-04 19:43:26,022 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:43:26,024 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 19:43:26,025 - INFO - start process : top -H
2025-04-04 19:43:26,134 - INFO - Broker version identified as 2.5.0
2025-04-04 19:43:26,134 - INFO - Set configuration api_version=(2, 5, 0) to skip auto check_version requests on startup
2025-04-04 19:43:26,135 - WARNING - group_id is None: disabling auto-commit.
2025-04-04 19:43:26,135 - INFO - Updating subscribed topics to: ('cameralist',)
2025-04-04 19:43:26,135 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 19:43:26,144 - INFO - Updated partition assignment: [TopicPartition(topic='cameralist', partition=0)]
2025-04-04 19:43:26,144 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:43:26,244 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:43:26,245 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. 
2025-04-04 19:43:53,663 - INFO - Exiting program, stopping all processes...
2025-04-04 19:43:53,680 - ERROR - Error stopping process top (PID: 37032): [Errno 1] Operation not permitted
2025-04-04 19:43:53,680 - INFO - Sent SIGTERM to process: top (PID: 39230)
2025-04-04 19:44:30,568 - INFO - parkwatch Program started
2025-04-04 19:44:30,572 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 19:44:30,576 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:44:30,576 - INFO - Probing node bootstrap-0 broker version
2025-04-04 19:44:30,577 - INFO - Waiting 15979.422491 seconds until the next cleanup task.
2025-04-04 19:44:30,580 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:44:30,584 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 19:44:30,585 - INFO - start process : top -H
2025-04-04 19:44:30,689 - INFO - Broker version identified as 2.5.0
2025-04-04 19:44:30,689 - INFO - Set configuration api_version=(2, 5, 0) to skip auto check_version requests on startup
2025-04-04 19:44:30,690 - WARNING - group_id is None: disabling auto-commit.
2025-04-04 19:44:30,690 - INFO - Updating subscribed topics to: ('cameralist',)
2025-04-04 19:44:30,690 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 19:44:30,696 - INFO - Updated partition assignment: [TopicPartition(topic='cameralist', partition=0)]
2025-04-04 19:44:30,696 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 19:44:30,797 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 19:44:30,797 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. 
2025-04-04 19:44:34,701 - INFO - Exiting program, stopping all processes...
2025-04-04 19:44:34,741 - ERROR - Error stopping process top (PID: 37032): [Errno 1] Operation not permitted
2025-04-04 19:44:34,741 - INFO - Sent SIGTERM to process: top (PID: 39314)
2025-04-04 20:05:47,921 - INFO - parkwatch Program started
2025-04-04 20:05:47,925 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 20:05:47,928 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 20:05:47,928 - INFO - Probing node bootstrap-0 broker version
2025-04-04 20:05:47,930 - INFO - Waiting 14702.069914 seconds until the next cleanup task.
2025-04-04 20:05:47,933 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 20:05:47,937 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 20:05:47,937 - INFO - start process : top -H
2025-04-04 20:05:48,043 - INFO - Broker version identified as 2.5.0
2025-04-04 20:05:48,043 - INFO - Set configuration api_version=(2, 5, 0) to skip auto check_version requests on startup
2025-04-04 20:05:48,044 - WARNING - group_id is None: disabling auto-commit.
2025-04-04 20:05:48,044 - INFO - Updating subscribed topics to: ('cameralist',)
2025-04-04 20:05:48,044 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 20:05:48,049 - INFO - Updated partition assignment: [TopicPartition(topic='cameralist', partition=0)]
2025-04-04 20:05:48,050 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 20:05:48,150 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 20:05:48,150 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. 
2025-04-04 20:05:51,981 - INFO - Exiting program, stopping all processes...
2025-04-04 20:05:51,997 - ERROR - Error stopping process top (PID: 37032): [Errno 1] Operation not permitted
2025-04-04 20:05:52,006 - INFO - Sent SIGTERM to process: top (PID: 40301)
2025-04-04 20:49:04,081 - WARNING - Process top is not running, starting...
2025-04-04 20:49:04,082 - INFO - start process : top -H
2025-04-04 20:57:11,814 - WARNING - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]> timed out after 305000 ms. Closing connection.
2025-04-04 20:57:11,815 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connected> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. [Error 7] RequestTimedOutError: Request timed out after 305000 ms
2025-04-04 20:57:11,815 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 20:57:11,816 - ERROR - Fetch to node 0 failed: [Error 7] RequestTimedOutError: Request timed out after 305000 ms
2025-04-04 20:57:11,817 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 20:59:26,102 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 20:59:26,103 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 20:59:26,103 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 20:59:26,104 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:01:41,270 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:01:41,270 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:01:41,271 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:01:41,271 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:03:56,438 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:03:56,439 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:03:56,439 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:03:56,440 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:06:11,607 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:06:11,607 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:06:11,607 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:06:11,608 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:08:26,774 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:08:26,775 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:08:26,775 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:08:26,776 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:10:41,942 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:10:41,943 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:10:41,943 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:10:41,944 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:12:57,110 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:12:57,110 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:12:57,110 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:12:57,111 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:15:12,278 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:15:12,279 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:15:12,280 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:15:12,280 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:17:27,446 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:17:27,447 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:17:27,447 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:17:27,448 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:19:42,614 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:19:42,615 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:19:42,615 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:19:42,616 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:21:57,782 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:21:57,783 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:21:57,783 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:21:57,784 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:24:12,950 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:24:12,951 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:24:12,951 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:24:12,952 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:25:35,830 - INFO - parkwatch Program started
2025-04-04 21:25:35,834 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:25:35,837 - INFO - Waiting 9914.162645 seconds until the next cleanup task.
2025-04-04 21:25:35,838 - INFO - <BrokerConnection node_id=bootstrap-0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:25:35,838 - INFO - Probing node bootstrap-0 broker version
2025-04-04 21:25:35,845 - INFO - stop success {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} (PID: 42122)
2025-04-04 21:25:35,846 - INFO - start process : top -H
2025-04-04 21:25:59,524 - INFO - parkwatch Program started
2025-04-04 21:25:59,528 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:26:06,899 - INFO - Waiting 9883.100364 seconds until the next cleanup task.
2025-04-04 21:26:28,118 - ERROR - Connect attempt to <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]> returned error 110. Disconnecting.
2025-04-04 21:26:28,118 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Closing connection. KafkaConnectionError: 110 ETIMEDOUT
2025-04-04 21:26:28,118 - WARNING - Node 0 connection failed -- refreshing metadata
2025-04-04 21:26:28,119 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: connecting to 192.168.0.78:9092 [('192.168.0.78', 9092) IPv4]
2025-04-04 21:26:28,124 - INFO - <BrokerConnection node_id=0 host=192.168.0.78:9092 <connecting> [IPv4 ('192.168.0.78', 9092)]>: Connection complete.
2025-04-04 21:26:40,266 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:26:40,284 - INFO - stop success {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} (PID: 44577)
2025-04-04 21:26:40,285 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 21:26:40,286 - INFO - start process : top -H
2025-04-04 21:26:52,970 - INFO - parkwatch Program started
2025-04-04 21:26:52,974 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:26:52,983 - INFO - Waiting 9837.016993 seconds until the next cleanup task.
2025-04-04 21:26:52,993 - ERROR - stop process {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} faild: [Errno 1] Operation not permitted
2025-04-04 21:26:52,994 - INFO - stop success {'program_path': 'gnome-terminal', 'commands': 'top -H', 'process_name': 'top'} (PID: 44849)
2025-04-04 21:26:52,995 - INFO - start process : top -H
2025-04-04 21:26:53,099 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:33:38,528 - INFO - Exiting program, stopping all processes...
2025-04-04 21:33:38,539 - ERROR - Error stopping process top (PID: 44641): [Errno 1] Operation not permitted
2025-04-04 21:33:38,539 - INFO - Sent SIGTERM to process: top (PID: 44974)
2025-04-04 21:33:38,792 - INFO - Exiting program, stopping all processes...
2025-04-04 21:33:38,831 - ERROR - Error stopping process top (PID: 44641): [Errno 1] Operation not permitted
2025-04-04 21:34:23,995 - INFO - parkwatch Program started
2025-04-04 21:34:23,999 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:34:24,010 - INFO - Waiting 9385.989625 seconds until the next cleanup task.
2025-04-04 21:34:24,023 - INFO - start process : top -H
2025-04-04 21:34:24,037 - INFO - start process : top -H
2025-04-04 21:34:24,124 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:34:49,743 - INFO - parkwatch Program started
2025-04-04 21:34:49,746 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:34:49,751 - INFO - Waiting 9360.248999 seconds until the next cleanup task.
2025-04-04 21:34:49,761 - INFO - start process : top -H
2025-04-04 21:34:49,774 - INFO - start process : top -H
2025-04-04 21:34:49,865 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:34:59,820 - INFO - start process : top -H
2025-04-04 21:35:09,865 - INFO - start process : top -H
2025-04-04 21:35:14,671 - INFO - Exiting program, stopping all processes...
2025-04-04 21:35:19,450 - INFO - parkwatch Program started
2025-04-04 21:35:19,453 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:35:19,458 - INFO - Waiting 9330.541146 seconds until the next cleanup task.
2025-04-04 21:35:19,467 - INFO - start process : top -H
2025-04-04 21:35:19,479 - INFO - start process : top -H
2025-04-04 21:35:19,572 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:35:22,089 - INFO - Exiting program, stopping all processes...
2025-04-04 21:35:22,125 - INFO - Sent SIGTERM to process: top (PID: 45753)
2025-04-04 21:35:23,127 - INFO - Sent SIGTERM to process: top (PID: 45754)
2025-04-04 21:36:15,996 - INFO - parkwatch Program started
2025-04-04 21:36:16,000 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:36:16,004 - INFO - Waiting 9273.995299 seconds until the next cleanup task.
2025-04-04 21:36:16,014 - INFO - start process : top -H
2025-04-04 21:36:16,116 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:36:24,885 - INFO - Exiting program, stopping all processes...
2025-04-04 21:36:24,923 - INFO - Sent SIGTERM to process: top (PID: 45856)
2025-04-04 21:36:28,949 - INFO - parkwatch Program started
2025-04-04 21:36:28,952 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:36:28,956 - INFO - Waiting 9261.043771 seconds until the next cleanup task.
2025-04-04 21:36:28,965 - INFO - start process : top -H
2025-04-04 21:36:29,070 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:36:30,837 - INFO - Exiting program, stopping all processes...
2025-04-04 21:36:30,879 - INFO - Sent SIGTERM to process: top (PID: 45927)
2025-04-04 21:37:15,823 - INFO - parkwatch Program started
2025-04-04 21:37:15,826 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:37:15,830 - INFO - Waiting 9214.169995 seconds until the next cleanup task.
2025-04-04 21:37:15,949 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:37:25,890 - INFO - Exiting program, stopping all processes...
2025-04-04 21:37:25,906 - INFO - Sent SIGTERM to process: top (PID: 46020)
2025-04-04 21:42:27,602 - WARNING - Process top is not running, starting...
2025-04-04 21:42:27,603 - INFO - start process : top -H
2025-04-04 21:42:47,699 - WARNING - Process top is not running, starting...
2025-04-04 21:42:47,700 - INFO - start process : top -H
2025-04-04 21:44:05,865 - INFO - parkwatch Program started
2025-04-04 21:44:05,868 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:44:05,884 - INFO - Waiting 8804.11604 seconds until the next cleanup task.
2025-04-04 21:44:27,115 - INFO - parkwatch Program started
2025-04-04 21:44:27,119 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:44:27,129 - INFO - Waiting 8782.870118 seconds until the next cleanup task.
2025-04-04 21:44:27,250 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:48:37,792 - INFO - parkwatch Program started
2025-04-04 21:48:37,797 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:48:37,806 - INFO - Waiting 8532.193097 seconds until the next cleanup task.
2025-04-04 21:48:37,933 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:49:14,695 - INFO - parkwatch Program started
2025-04-04 21:49:14,698 - INFO - Successfully loaded process data from /home/pc1/Public/message_kafka/process_list.json
2025-04-04 21:49:14,702 - INFO - Waiting 8495.297645 seconds until the next cleanup task.
2025-04-04 21:49:14,713 - INFO - start process : top -H
2025-04-04 21:49:14,815 - INFO - subscribe Kafka topic : cameralist success!
2025-04-04 21:49:17,708 - INFO - Exiting program, stopping all processes...
2025-04-04 21:49:17,748 - INFO - Sent SIGTERM to process: top (PID: 47992)
2025-04-04 21:52:20,207 - WARNING - Process top is not running, starting...
2025-04-04 21:52:20,208 - INFO - start process : top -H
2025-04-04 23:40:20,345 - INFO - Exiting program, stopping all processes...
2025-04-04 23:40:20,363 - ERROR - Error stopping process top (PID: 48951): [Errno 1] Operation not permitted