diff --git a/heka/files/input/amqp.toml b/heka/files/input/amqp.toml
index 2611b90..2b4abfb 100644
--- a/heka/files/input/amqp.toml
+++ b/heka/files/input/amqp.toml
@@ -3,6 +3,9 @@
 url = "amqp://{{ values.user }}:{{ values.password }}@{{ values.host }}:{{ values.port }}/{{ values.vhost }}"
 exchange = "{{ values.exchange }}"
 exchange_type = "{{ values.exchange_type }}"
+{%- if values.prefetch_count is defined -%}
+prefetch_count = {{ values.prefetch_count }}
+{% endif %}
 {%- if values.exchange_durability is defined -%}
 exchange_durability = "{{ values.exchange_durability }}"
 {% endif %}