src/Resources/config/services.xml
<?xml version="1.0" encoding="UTF-8" ?>
<container xmlns="http://symfony.com/schema/dic/services"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://symfony.com/schema/dic/services
http://symfony.com/schema/dic/services/services-1.0.xsd">
<services>
<service id="Koco\Kafka\RdKafka\RdKafkaFactory" class="Koco\Kafka\RdKafka\RdKafkaFactory" public="false" />
<service id="Koco\Kafka\Messenger\KafkaTransportFactory" class="Koco\Kafka\Messenger\KafkaTransportFactory" public="false">
<tag name="messenger.transport_factory"/>
<argument type="service" id="Koco\Kafka\RdKafka\RdKafkaFactory"/>
<argument type="service" id="logger" on-invalid="null"/>
</service>
<service id="Koco\Kafka\Messenger\RestProxyTransportFactory" class="Koco\Kafka\Messenger\RestProxyTransportFactory" public="false">
<tag name="messenger.transport_factory"/>
<argument type="service" id="logger" on-invalid="null"/>
<argument type="service" id="Psr\Http\Client\ClientInterface" on-invalid="null"/>
<argument type="service" id="Psr\Http\Message\RequestFactoryInterface" on-invalid="null"/>
<argument type="service" id="Psr\Http\Message\UriFactoryInterface" on-invalid="null"/>
<argument type="service" id="Psr\Http\Message\StreamFactoryInterface" on-invalid="null"/>
</service>
</services>
</container>