How can I use the Symfony Bundle with Kafka?

[dergriewatz]

When I try this transport layer configuration:

# app/config/config.yml

enqueue:
    transport:
        default: "kafka:"
    client: ~

I get this Exception:

In DefaultTransportFactory.php line 212:

  [LogicException]
  There is no supported transport factory for the connection factory "Enqueue\RdKafka\RdKafkaConnectionFactory" created from DSN "kafka:"

Exception trace:
 Enqueue\Symfony\DefaultTransportFactory->findFactory() at vendor/enqueue/enqueue/Symfony/DefaultTransportFactory.php:82
 Enqueue\Symfony\DefaultTransportFactory->createConnectionFactory() at vendor/enqueue/enqueue-bundle/DependencyInjection/EnqueueExtension.php:76
 Enqueue\Bundle\DependencyInjection\EnqueueExtension->load() at vendor/symfony/dependency-injection/Compiler/MergeExtensionConfigurationPass.php:71
 Symfony\Component\DependencyInjection\Compiler\MergeExtensionConfigurationPass->process() at vendor/symfony/http-kernel/DependencyInjection/MergeExtensionConfigurationPass.php:39
 Symfony\Component\HttpKernel\DependencyInjection\MergeExtensionConfigurationPass->process() at vendor/symfony/dependency-injection/Compiler/Compiler.php:95
 Symfony\Component\DependencyInjection\Compiler\Compiler->compile() at vendor/symfony/dependency-injection/ContainerBuilder.php:713
 Symfony\Component\DependencyInjection\ContainerBuilder->compile() at vendor/symfony/http-kernel/Kernel.php:513
 Symfony\Component\HttpKernel\Kernel->initializeContainer() at vendor/symfony/http-kernel/Kernel.php:125
 Symfony\Component\HttpKernel\Kernel->boot() at vendor/symfony/framework-bundle/Console/Application.php:64
 Symfony\Bundle\FrameworkBundle\Console\Application->doRun() at vendor/symfony/console/Application.php:143
 Symfony\Component\Console\Application->run() at bin/console:39

[makasim]

$ composer req enqueue/rdkafka

[dergriewatz]

It's already installed.

# composer.json
{
    ...
    "require": {
        "enqueue/enqueue-bundle": "^0.8.25",
        "enqueue/rdkafka": "^0.8.23",
        ...
    },
    ...
}

[makasim]

The kafka factory has to be added to the method: https://github.com/php-enqueue/enqueue-dev/blob/master/pkg/enqueue/Symfony/DefaultTransportFactory.php#L176

[dergriewatz]

I only found the Enqueue\RdKafka\RdKafkaConnectionFactory that implements the PsrConnectionFactory interface.
But when I see it right I need a Enqueue\RdKafka\Symfony\RdKafkaTransportFactory or similar that implements the TransportFactoryInterface and DriverFactoryInterface.
Is there already something like that?

[makasim]

It's not been implemented.

[dergriewatz]

Okay thanks. I try to implement it and make a PR.

[makasim]

Closing as there is PR #432