summaryrefslogtreecommitdiffstats
path: root/python/fatcat_tools/workers/changelog.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/fatcat_tools/workers/changelog.py')
-rw-r--r--python/fatcat_tools/workers/changelog.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/python/fatcat_tools/workers/changelog.py b/python/fatcat_tools/workers/changelog.py
index 5ef1c69c..a753bb49 100644
--- a/python/fatcat_tools/workers/changelog.py
+++ b/python/fatcat_tools/workers/changelog.py
@@ -75,8 +75,8 @@ class EntityUpdatesWorker(FatcatWorker):
def run(self):
changelog_topic = self.kafka.topics[self.consume_topic]
release_topic = self.kafka.topics[self.release_topic]
- file_topic = self.kafka.topics[self.release_topic]
- container_topic = self.kafka.topics[self.release_topic]
+ file_topic = self.kafka.topics[self.file_topic]
+ container_topic = self.kafka.topics[self.container_topic]
consumer = changelog_topic.get_balanced_consumer(
consumer_group=self.consumer_group,