Merge 809fbb9 into 0aad65b

docs/publisher/index.rst

@@ -325,3 +325,20 @@ You can specify a separate serialize per publisher, e.g.:
         serializer: json
     - cli:
         serializer: pprint
+
+.. _publisher-opts-strip-message-details:
+
+``strip_message_details``: ``False``
+------------------------------------
+
+.. versionadded:: 0.7.0
+
+Strip the ``message_details`` key before publishing the object.
+
+Configuration example:
+
+.. code-block:: yaml
+
+  publisher:
+    - kafka:
+        strip_message_details: true

napalm_logs/publisher.py

@@ -61,6 +61,7 @@ def __init__(self,
         if not disable_security:
             self.__safe = nacl.secret.SecretBox(private_key)
             self.__signing_key = signing_key
+        self._strip_message_details = publisher_opts.pop('strip_message_details', False)
         self._setup_transport()
 
     def _exit_gracefully(self, signum, _):
@@ -166,6 +167,9 @@ def start(self):
                     log.error(error, exc_info=True)
                     raise NapalmLogsExit(error)
             obj = umsgpack.unpackb(bin_obj)
+            if self._strip_message_details:
+                obj.pop('message_details', None)
+                bin_obj = self.serializer_fun(obj)
             napalm_logs_publisher_received_messages.labels(
                 publisher_type=self._transport_type,
                 address=self.address,