Handle delete events from change log where there is no after (#73)

changelog/2.bugfix.md

@@ -0,0 +1 @@
+Move Resource Config Selector class to public

changelog/3.bugfix.md

@@ -0,0 +1 @@
+Handle delete events from change log where there is no after

port_ocean/core/event_listener/kafka/event_listener.py

@@ -52,10 +52,13 @@ async def _get_kafka_config(self) -> KafkaConsumerConfig:
 
         return KafkaConsumerConfig.parse_obj(self.event_listener_config.dict())
 
-    def should_be_processed(self, msg_value: dict[Any, Any], topic: str) -> bool:
-        integration_identifier = (
-            msg_value.get("diff", {}).get("after", {}).get("identifier")
-        )
+    def _should_be_processed(self, msg_value: dict[Any, Any], topic: str) -> bool:
+        after = msg_value.get("diff", {}).get("after", {})
+        # handles delete events from change log where there is no after
+        if after is None:
+            return False
+
+        integration_identifier = after.get("identifier")
         if integration_identifier == self.integration_identifier and (
             "change.log" in topic
         ):
@@ -64,7 +67,7 @@ def should_be_processed(self, msg_value: dict[Any, Any], topic: str) -> bool:
         return False
 
     async def _handle_message(self, message: dict[Any, Any], topic: str) -> None:
-        if not self.should_be_processed(message, topic):
+        if not self._should_be_processed(message, topic):
             return
 
         if "change.log" in topic and message is not None: