diff --git a/roles/openshift-apps/bugzilla2fedmsg/templates/fedora-messaging.toml b/roles/openshift-apps/bugzilla2fedmsg/templates/fedora-messaging.toml
index 971492b76f..ad5c44fedf 100644
--- a/roles/openshift-apps/bugzilla2fedmsg/templates/fedora-messaging.toml
+++ b/roles/openshift-apps/bugzilla2fedmsg/templates/fedora-messaging.toml
@@ -20,19 +20,37 @@ certfile = "/etc/pki/fedora-messaging/bugzilla2fedmsg-cert.pem"
 [consumer_config]
     fasjson_url = "https://fasjson{{ env_suffix }}.fedoraproject.org"
 
+    {% if env == "staging" %}
+    [consumer_config.kafka]
+    # Kafka servers
+    # https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html
+    {% if env == "staging" %}
+    servers = [
+        "b-1.itpreprod.sui7dp.c7.kafka.us-east-1.amazonaws.com:9096",
+        "b-2.itpreprod.sui7dp.c7.kafka.us-east-1.amazonaws.com:9096",
+        "b-6.itpreprod.sui7dp.c7.kafka.us-east-1.amazonaws.com:9096",
+    ]
+    username = "{{ redhat_kafka_staging_username }}"
+    password = "{{ redhat_kafka_staging_password }}"
+    topics = ["qa.ants.engineering.bugzilla.bug", "stage.ants.engineering.bugzilla.bug"]
+    {% else %}
+    servers = [
+        "b-3.itprod.bvduhl.c8.kafka.us-east-1.amazonaws.com:9096",
+        "b-2.itprod.bvduhl.c8.kafka.us-east-1.amazonaws.com:9096",
+        "b-1.itprod.bvduhl.c8.kafka.us-east-1.amazonaws.com:9096",
+    ]
+    username = "{{ redhat_kafka_prod_username }}"
+    password = "{{ redhat_kafka_prod_password }}"
+    topics = ["ants.engineering.bugzilla.bug"]
+    {% endif %}
+    {% else %}
     [consumer_config.stomp]
     # Broker URI
     # http://nikipore.github.io/stompest/protocol.html#stompest.protocol.failover.StompFailoverUri
     # Example: failover:(tcp://remote1:61615,tcp://localhost:61616)?randomize=false,startupMaxReconnectAttempts=3,initialReconnectDelay=7,maxReconnectDelay=8,maxReconnectAttempts=0
-{% if env == 'staging' %}
-    uri = "ssl://umb.stage.api.redhat.com:61612"
-    user = "{{ redhat_dmz_dev_broker_username }}"
-    pass = "{{ redhat_dmz_dev_broker_password }}"
-{% else %}
     uri = "ssl://umb.api.redhat.com:61612"
     user = "{{ redhat_dmz_prod_broker_username }}"
     pass = "{{ redhat_dmz_prod_broker_password }}"
-{% endif %}
     ssl_crt = "/etc/pki/stomp/msg-client-fedora-prod.crt"
     ssl_key = "/etc/pki/stomp/msg-client-fedora-prod.key"
 
@@ -44,6 +62,7 @@ certfile = "/etc/pki/fedora-messaging/bugzilla2fedmsg-cert.pem"
 
     # How many messages to prefetch
     prefetch_size = 100
+    {% endif %}
 
     [consumer_config.bugzilla]
     # Products to relay messages for - messages for bugs files against