Change kafka queue exchange name

468df39a · Geoffrey Mo · Cody Messick · be0be84d · 468df39a
Commit 468df39a authored 3 years ago by Geoffrey Mo Committed by Cody Messick 2 years ago
--- a/gwcelery/conf/__init__.py
+++ b/gwcelery/conf/__init__.py
@@ -89,7 +89,7 @@ scimma_topic_name = 'lvk-emfollow.gwalert-playground'
 kafka_queue_name = 'kafka'
 """Kafka queue name"""

-kafka_queue_exchange_name = 'kafka'
+kafka_queue_exchange_name = 'default'
 """Kafka queue exchange name"""

 kafka_queue_routing_key = 'kafka.key'