fix topic claim log

block · Dec 18, 2024 · 34baf3a · 34baf3a
1 parent ea1c55e
commit 34baf3a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/backend/runner/pubsub/consumer.go b/backend/runner/pubsub/consumer.go
@@ -142,7 +142,7 @@ func (c *consumer) subscribe(ctx context.Context, group sarama.ConsumerGroup) {
 func (c *consumer) Setup(session sarama.ConsumerGroupSession) error {
 	logger := log.FromContext(session.Context())
 
-	partitions := session.Claims()[kafkaConsumerGroupID(c.moduleName, c.verb)]
+	partitions := session.Claims()[c.kafkaTopicID()]
 	logger.Infof("Starting consume session for subscription %s with partitions: [%v]", c.verb.Name, strings.Join(slices.Map(partitions, func(partition int32) string { return strconv.Itoa(int(partition)) }), ","))
 
 	return nil