in_mqtt.rb in fluent-plugin-mqtt-io-0.3.8

- old
+ new

@@ -12,11 +12,14 @@
 
     helpers :compat_parameters, :parser
 
     desc 'The topic to subscribe.'
     config_param :topic, :string, default: '#'
-    desc 'The format to receive.'
-    config_param :format, :string, default: 'json'
+
+    config_section :parse do
+      desc 'The format to receive.'
+      config_param :@type, :string, default: 'none'
+    end
 
     # bulk_trans is deprecated
     # multiple entries must be inputted as an Array
     #config_param :bulk_trans, :bool, default: true
     #config_param :bulk_trans_sep, :string, default: "\t"