diff --git a/heka/files/output/amqp.toml b/heka/files/output/amqp.toml
index f097633..5ca1498 100644
--- a/heka/files/output/amqp.toml
+++ b/heka/files/output/amqp.toml
@@ -5,7 +5,7 @@
 exchange_type = "fanout"
 message_matcher = "{{ values.message_matcher }}"
 use_framing = true
-encoder = "ProtobufEncoder"
+encoder = "{{ values.encoder }}
 
 [AMQPOutput.retries]
 max_delay = "30s"