Skip to content

Commit 1a596db

Browse files
author
Ralf Kuehnel
committed
fix kafka consumer configuration
1 parent 2cef487 commit 1a596db

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

packages/Kafka/src/Configuration/KafkaModule.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ public function prepare(Configuration $messagingConfiguration, array $extensionO
117117

118118
foreach ($extensionObjects as $extensionObject) {
119119
if ($extensionObject instanceof KafkaConsumerConfiguration) {
120-
$consumerConfigurations[$extensionObject->getEndpointId()] = $consumerConfigurations;
120+
$consumerConfigurations[$extensionObject->getEndpointId()] = $extensionObject;
121121
} elseif ($extensionObject instanceof TopicConfiguration) {
122122
$topicConfigurations[$extensionObject->getTopicName()] = $extensionObject;
123123
$topicReferenceMapping[$extensionObject->referenceName] = $extensionObject->getTopicName();

0 commit comments

Comments
 (0)