Merge pull request #144 from u2d-ai/SAM-543/fix_incorrect_messages_from_kafka

Sam 543/fix incorrect messages from kafka

Author: SekachVitaliy

docs/release-notes.md

@@ -1,6 +1,11 @@
 # msaBase Release Notes
 ## Possible future features:
 
+## 0.0.135
+
+- fix logging and create message for Kafka
+- update msaDocModels version
+
 ## 0.0.134
 
 - Updated sending messages to Kafka

docs/saved_req_package_pip_info.pkl

@@ -1,7 +1,7 @@
 import glob
 from os.path import basename, dirname, isfile, join
 
-version = "0.0.134"
+version = "0.0.135"
 __author__ = "Stefan Welcker"
 __copyright__ = "Copyright 2022, U2D.ai"
 __license__ = "MIT"

msaBase/__init__.py

@@ -216,7 +216,7 @@ def create_kafka_endpoint(self) -> None:
         Subscribes service to Kafka topic through which new configs will be received.
         """
         if not ENABLE_MESSAGE_QUEUE:
-            self.logger_info(f"Kafka is not enabled. Skipping Kafka consumer creation for topic {SERVICE_TOPIC}.")
+            self.logger.info(f"Kafka is not enabled. Skipping Kafka consumer creation for topic {SERVICE_TOPIC}.")
         else:
             threading.Thread(target=self._consume_kafka_messages, daemon=True).start()
 
@@ -336,7 +336,7 @@ def logger_info(self, message: str, service_name: str, topic_name: str = "") ->
         if topic_name and ENABLE_MESSAGE_QUEUE:
             try:
                 producer = self.producer or KafkaUtils.get_producer()
-                model = MessageInput(service_name=service_name, data=message).json()
+                model = MessageInput(service_name=service_name, message=message).json()
                 serialized_value = KafkaUtils.serialize_value(model)
                 producer.produce(topic_name, serialized_value)
                 producer.flush(timeout=KAFKA_TIMEOUT)

msaBase/configurate.py

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "msaBase"
-version = "0.0.134"
+version = "0.0.135"
 description = "General Package for Microservices based on FastAPI like Profiler, Scheduler, Sysinfo, Healtcheck, Error Handling etc."
 authors = ["Stefan Welcker"]
 readme = "README.md"
@@ -38,7 +38,7 @@ count = true
 [tool.poetry.dependencies]
 python = ">=3.9.0,<3.11"
 msaFileSystem = "0.0.8"
-msaDocModels = "0.0.113"
+msaDocModels = "0.0.114"
 anyio = "3.7.1"
 fastapi = {extras = ["all"], version = "0.86.0"}
 fastapi_utils = "0.2.1"