Logstash Module - Pull from unparsed

salt/filebeat/init.sls

@@ -29,12 +29,13 @@ filebeatpkidir:
     - group: 939
     - makedirs: True
 
+# This needs to be owned by root
 filebeatconfsync:
   file.recurse:
     - name: /opt/so/conf/filebeat/etc
     - source: salt://filebeat/etc
-    - user: 939
-    - group: 939
+    - user: 0
+    - group: 0
     - template: jinja
 
 #filebeatcrt:

salt/logstash/files/dynamic/0900_input_redis.conf

@@ -3,7 +3,7 @@ input {
 	redis {
 		host => '{{ master }}'
 		data_type => 'list'
-		key => 'logstash:redis'
+		key => 'logstash:unparsed'
 		type => 'redis-input'
 		# threads => 1
 	}