diff --git a/docker/files/docker-compose.yml b/docker/files/docker-compose.yml
index a0c47c6..1228fa1 100644
--- a/docker/files/docker-compose.yml
+++ b/docker/files/docker-compose.yml
@@ -19,6 +19,10 @@
   {%- set service_extra_hosts_list = srv.get('extra_hosts', []) %}
   {%- do srv.update({'extra_hosts': (default_extra_hosts_list + service_extra_hosts_list)|unique|sort}) %}
   {{ name }}:
+    logging:
+      driver: journald
+      options:
+        tag: {% raw %}'docker.{{.Name}}'{% endraw %}
     {{ srv|yaml(False)|indent(4) }}
   {%- set env_file_set = False %}
   {%- if 'env_file' in srv.keys() %}{%- set env_file_set = True %}{%- endif %}
diff --git a/docker/meta/fluentd.yml b/docker/meta/fluentd.yml
index 759614b..4d977e7 100644
--- a/docker/meta/fluentd.yml
+++ b/docker/meta/fluentd.yml
@@ -4,43 +4,30 @@
   config:
     label:
       docker:
-        enabled: false
-        input:
-          container:
-            type: tail
-            tag: temp.docker.container.*
-            path: /var/lib/docker/containers/*/*-json.log
-            path_key: log_path
-            pos_file: {{ positiondb }}/docker.container.pos
-            parser:
-              type: json
-              time_format: '%Y-%m-%dT%H:%M:%S.%NZ'
-              keep_time_key: false
         filter:
           enrich:
-            tag: 'temp.docker.container.**'
+            tag: 'docker.**'
             type: record_transformer
             enable_ruby: true
-            remove_keys: log
             record:
-              - name: severity_label
-                value: INFO
-              - name: Severity
-                value: 6
               - name: programname
-                value: docker
-              - name: Payload
-                value: ${record['log']}
+                value: ${ if record["ident"] == "dockerd"; "dockerd" else record["ident"].split(".")[1] end }
+              - name: severity_label
+                value: ${ if record["Payload"].downcase.include? " error"; "ERROR"; elsif record["Payload"].downcase.include? " warn"; "WARNING"; elsif record["Payload"].downcase.include? " debug"; "DEBUG"; elsif record["Payload"].downcase.include? " debg"; "DEBUG" else; "INFO"; end }
+          add_severity:
+            require:
+              - enrich
+            tag: 'docker.**'
+            type: record_transformer
+            enable_ruby: true
+            record:
+              - name: service
+                value: docker.${ if record["ident"] == "dockerd"; "service" ; else; record["programname"]; end }
+              - name: Severity
+                value: '${ { 8=>"TRACE",7=>"DEBUG",6=>"INFO",5=>"NOTICE",4=>"WARNING",3=>"ERROR",2=>"CRITICAL",1=>"ALERT",0=>"EMERGENCY" }.key(record["severity_label"]) }'
         match:
-          cast_service_tag:
-            tag: 'temp.docker.container.**'
-            type: rewrite_tag_filter
-            rule:
-              - name: log_path
-                regexp: '^.*\/(.*)-json\.log$'
-                result: docker.container.$1
           push_to_default:
-            tag: 'docker.container.*'
+            tag: 'docker.**'
             type: relabel
             label: default_output
 {%- endif %}