Merge branch 'main' into graylog_integration

resources/loki.configuration.json.example

@@ -46,4 +46,4 @@
   "value" : "",
   "type" : "string"
  },
-]
+]

src/scicat_ingestor.py

@@ -64,8 +64,8 @@ def main() -> None:
 
                 # instantiate a new process and runs backeground ingestor
                 # on the nexus file
-                pass
+                ...
 
             # check if we need to commit the individual message
-            if config.kafka_options.individual_message_commit:
+            elif config.kafka_options.individual_message_commit:
                 consumer.commit(message=message)

src/scicat_kafka.py

@@ -129,7 +129,7 @@ def wrdn_messages(
             message_value = message.value()
             message_type = message_value[4:8]
             logger.info("Received message. Type : %s", message_type)
-            if message_value == b"wrdn":
-                yield _deserialise_wrdn(message.value(), logger)
+            if message_type == b"wrdn":
+                yield _deserialise_wrdn(message_value, logger)
             else:
                 yield None