Skip to content

Commit

Permalink
chore: remove merge from consumer config middlewares
Browse files Browse the repository at this point in the history
  • Loading branch information
hcdias committed Oct 17, 2023
1 parent 468b5c8 commit 2f781c0
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions src/Connectors/Consumer/Config.php
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
}

0 comments on commit 2f781c0

Please sign in to comment.