Corrected KafkaFactory service parameter

andythorne · andythorne · commit 91f586ad1c85 · 2023-08-11T21:07:22.000+01:00
diff --git a/src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.php b/src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.php
@@ -16,7 +16,6 @@
 use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransportFactory;
 use Symfony\Component\Messenger\Bridge\Beanstalkd\Transport\BeanstalkdTransportFactory;
 use Symfony\Component\Messenger\Bridge\Kafka\Callback\CallbackManager;
-use Symfony\Component\Messenger\Bridge\Kafka\Callback\CallbackProcessorInterface;
 use Symfony\Component\Messenger\Bridge\Kafka\Transport\KafkaFactory;
 use Symfony\Component\Messenger\Bridge\Kafka\Transport\KafkaTransportFactory;
 use Symfony\Component\Messenger\Bridge\Redis\Transport\RedisTransportFactory;
@@ -157,7 +156,7 @@
             ])
         ->set(KafkaFactory::class)
             ->args([
-                service(CallbackProcessorInterface::class),
+                service(CallbackManager::class),
             ])
         ->set('messenger.transport.kafka.factory', KafkaTransportFactory::class)
             ->args([
