From 0e282609c517e58cee5ad44fbbfc1a584f45ce0c Mon Sep 17 00:00:00 2001 From: dspeck1 Date: Fri, 20 Sep 2024 14:13:10 -0500 Subject: [PATCH] Fix type error for topic. --- python/activator/activator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/activator/activator.py b/python/activator/activator.py index 154226e6..abcfae36 100644 --- a/python/activator/activator.py +++ b/python/activator/activator.py @@ -199,7 +199,7 @@ def keda_start(): "group.id": next_visit_kakfa_group_id, "auto.offset.reset": "earliest", }) - next_visit_fan_out_consumer.subscribe(next_visit_fan_out_topic) + next_visit_fan_out_consumer.subscribe([next_visit_fan_out_topic]) next_visit_fan_out_message = next_visit_fan_out_consumer.consume(num_messages=1, timeout=5) _log.info(next_visit_fan_out_message)