ikilobyte/pulsar-client-php

setTopic只能订阅一个topic

Closed this issue · 1 comments

jasonhe88 commented

谢谢为此项目的付出！

如题，看源代码只能有一个订阅topic

 public function setTopic(string $topic)
    {
        $this->data[ self::TOPICS ] = [$topic];
    }

建议改成能接受多个topic

public function setTopic(string $topic)
{
         if( ! isset($this->data[self::TOPICS]) ) {
                 $this->data[ self::TOPICS ] = [];
         }
         $this->data[ self::TOPICS ][] = $topic;
}

或者初始化时就初始化 $this->data[ self::TOPICS ] 成一个数组

jasonhe88 commented

发现ConsumerOptions 已经支持多主题订阅，请忽略

  • 😄1