diff --git a/packages/Kafka/src/Configuration/KafkaModule.php b/packages/Kafka/src/Configuration/KafkaModule.php
index 5b049fb29..a24edb7bd 100644
--- a/packages/Kafka/src/Configuration/KafkaModule.php
+++ b/packages/Kafka/src/Configuration/KafkaModule.php
@@ -117,7 +117,7 @@ public function prepare(Configuration $messagingConfiguration, array $extensionO
 
         foreach ($extensionObjects as $extensionObject) {
             if ($extensionObject instanceof KafkaConsumerConfiguration) {
-                $consumerConfigurations[$extensionObject->getEndpointId()] = $consumerConfigurations;
+                $consumerConfigurations[$extensionObject->getEndpointId()] = $extensionObject;
             } elseif ($extensionObject instanceof TopicConfiguration) {
                 $topicConfigurations[$extensionObject->getTopicName()] = $extensionObject;
                 $topicReferenceMapping[$extensionObject->referenceName] = $extensionObject->getTopicName();