diff --git a/src/Connectors/Consumer/Config.php b/src/Connectors/Consumer/Config.php index 673e36dd..0be88a80 100644 --- a/src/Connectors/Consumer/Config.php +++ b/src/Connectors/Consumer/Config.php @@ -91,16 +91,11 @@ protected function getTopicConfig(string $configName, string $topicId): array throw new ConfigurationException("Topic '{$topicId}' not found"); } - $globalMiddlewares = config( + $topicConfig['middlewares'] = config( 'kafka.middlewares.consumer', [] ); - $topicConfig['middlewares'] = array_merge( - $globalMiddlewares, - $topicConfig['consumer']['middlewares'] ?? [] - ); - return $topicConfig; } }