KIT-454 modified logged fields: added path, removed version

Author: gkreuzer

logstash_async/__init__.py

@@ -3,7 +3,7 @@
 # This software may be modified and distributed under the terms
 # of the MIT license.  See the LICENSE file for details.
 
-__version__ = '2.1.0'
+__version__ = '2.1.1'
 
 # When using an in-memory only cache, this persists the cache through
 # thread failures, shutdowns, and restarts.

logstash_async/formatter.py

@@ -74,11 +74,11 @@ def _prefetch_program_name(self):
     def format(self, record):
         message = {
             '@timestamp': self._format_timestamp(record.created),
-            '@version': '1',
             'host': self._host,
             'level': record.levelname,
             'logsource': self._logsource,
             'message': record.getMessage(),
+            'path': record.pathname,
             'process_id': record.process,
             'program': self._program_name,
             'type': self._message_type,