diff --git a/VERSION b/VERSION
index 54d1a4f..d23f7e6 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-0.13.0
+0.13.0-3
diff --git a/lib/fluent/plugin/in_amqp.rb b/lib/fluent/plugin/in_amqp.rb
index 3952a88..16bb380 100644
--- a/lib/fluent/plugin/in_amqp.rb
+++ b/lib/fluent/plugin/in_amqp.rb
@@ -32,6 +32,7 @@ class AMQPInput < Input
     config_param :exclusive, :bool, default: false
     config_param :auto_delete, :bool, default: false
     config_param :passive, :bool, default: false
+    config_param :prefetch, :integer, default: 0
     config_param :payload_format, :string, default: "json"
     config_param :tag_key, :bool, default: false
     config_param :tag_header, :string, default: nil
@@ -70,6 +71,10 @@ def start
       @connection.start
       @channel = @connection.create_channel
 
+      if @prefetch > 0
+        @channel.prefetch(@prefetch)
+      end
+
       if @exclusive && fluentd_worker_id > 0
         log.info 'Config requested exclusive queue with multiple workers'
         @queue += ".#{fluentd_worker_id}"