remove kafka exception block

Author: r14chandra

ros/processor/system_eraser.py

@@ -10,7 +10,6 @@
     GROUP_ID_SUGGESTIONS_ENGINE,
     POLL_TIMEOUT_SECS
 )
-from confluent_kafka import KafkaException
 from ros.lib import consume
 from ros.lib.app import app
 from ros.extensions import db
@@ -69,10 +68,6 @@ def run(self):
                 if message is None:
                     continue
 
-                if message.error():
-                    logging.error(f"{self.service} - Consumer error: {message.error()}")
-                    raise KafkaException(message.error())
-
                 try:
                     payload = json.loads(message.value().decode('utf-8'))
                     event_type = payload.get('type')

tests/test_system_eraser.py

@@ -77,7 +77,6 @@ def test_run_processes_delete_message(mock_app_context, mock_db_session, mock_co
     payload = {"type": "delete", "id": "host-999"}
     message = MagicMock()
     message.value.return_value = json.dumps(payload).encode("utf-8")
-    message.error.return_value = None  # No error
 
     # Consumer should return the message once then None
     mock_consumer.poll.side_effect = [message, None]
@@ -94,7 +93,6 @@ def test_run_ignores_non_delete_message(mock_app_context, mock_db_session, mock_
     payload = {"type": "update", "id": "host-777"}
     message = MagicMock()
     message.value.return_value = json.dumps(payload).encode("utf-8")
-    message.error.return_value = None  # No error
 
     mock_consumer.poll.side_effect = [message, None]