KIT-1010 use own cache for each worker

Author: oschulzSam

logstash_async/handler.py

@@ -52,7 +52,6 @@ def emit(self, record):
         self._setup_transport()
         self._start_worker_thread()
 
-        # basically same implementation as in logging.handlers.SocketHandler.emit()
         try:
             data = self._format_record(record)
             self._worker_thread.enqueue_event(data)
@@ -84,7 +83,7 @@ def _start_worker_thread(self):
             port=self._port,
             transport=self._transport,
             ssl_enable=self._ssl_enable,
-            cache=logstash_async.EVENT_CACHE,
+            cache={},
             event_ttl=self._event_ttl)
         self._worker_thread.start()