From 554b54768fb0c4af627fc2a88511ca08e738a8b3 Mon Sep 17 00:00:00 2001 From: Brage Date: Tue, 18 Jul 2023 04:05:33 +0200 Subject: [PATCH] Updated pyMetadata --- pyMetadata/app.py | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/pyMetadata/app.py b/pyMetadata/app.py index 33267014..9933c9fa 100644 --- a/pyMetadata/app.py +++ b/pyMetadata/app.py @@ -127,15 +127,20 @@ class MessageHandlerThread(threading.Thread): producerMessage = self.compose_message(referenceId=self.message.value["referenceId"], result=result) - # Serialiser resultatet til JSON - result_json = producerMessage.to_json() + # Serialiser resultatet til JSON som strenger + result_json = json.dumps(producerMessage.to_dict()) # Send resultatet tilbake ved hjelp av Kafka-producer - producer = KafkaProducer(bootstrap_servers=bootstrap_servers) + producer = KafkaProducer( + bootstrap_servers=bootstrap_servers, + key_serializer=lambda k: k.encode('utf-8') if isinstance(k, str) else None, + value_serializer=lambda v: v.encode('utf-8') if isinstance(v, str) else None + ) producer.send(kafka_topic, key="event:metadata:obtained", value=result_json) producer.close() + def perform_action(self, title) -> DataResult: anii = AniiMetadata(title) imdb = ImdbMetadata(title)