Merge pull request #567 from rosamarsky/fix-kafka-consuming

[rdkafka] Use default queue as router topic

Author: makasim

pkg/enqueue/Client/Driver/RdKafkaDriver.php

@@ -1,10 +1,11 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Client\Driver;
 
 use Enqueue\RdKafka\RdKafkaContext;
 use Enqueue\RdKafka\RdKafkaTopic;
-use Interop\Queue\Destination;
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
 
@@ -44,14 +45,4 @@ public function setupBroker(LoggerInterface $logger = null): void
             $this->getContext()->createConsumer($queue);
         }
     }
-
-    /**
-     * @return RdKafkaTopic
-     */
-    protected function createRouterTopic(): Destination
-    {
-        return $this->doCreateTopic(
-            $this->createTransportRouterTopicName($this->getConfig()->getRouterTopic(), true)
-        );
-    }
 }

pkg/enqueue/Client/Driver/RedisDriver.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Client\Driver;
 
 use Enqueue\Redis\RedisContext;

pkg/enqueue/Tests/Client/Driver/RdKafkaDriverTest.php

@@ -118,11 +118,6 @@ protected function createMessage(): InteropMessage
         return new RdKafkaMessage();
     }
 
-    protected function getRouterTransportName(): string
-    {
-        return 'aprefix.router';
-    }
-
     /**
      * @return Config
      */