Fix the bug that when topic is array (#482)

Co-authored-by: Deeka Wong <[email protected]>
friendsofhyperf · Dec 4, 2023 · cbe20d8 · cbe20d8
1 parent 13b0097
commit cbe20d8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/sentry/src/Tracing/Listener/TracingKafkaListener.php b/src/sentry/src/Tracing/Listener/TracingKafkaListener.php
@@ -59,9 +59,11 @@ public function process(object $event): void
     protected function startTransaction(BeforeConsume $event): void
     {
         $consumer = $event->getConsumer();
+        $topic = $consumer->getTopic();
+        $name = is_array($topic) ? implode(',', $topic) : $topic;
 
         $this->continueTrace(
-            name: $consumer->getTopic(),
+            name: $name,
             op: 'kafka.consume',
             description: $consumer::class,
             source: TransactionSource::custom()