改名
This commit is contained in:
@@ -31,7 +31,7 @@ class KafkaProviders extends Providers
|
|||||||
if (empty($kafka) || !($kafka['enable'] ?? false)) {
|
if (empty($kafka) || !($kafka['enable'] ?? false)) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (!isset($kafka['topics']) || empty($kafka['topics'])) {
|
if (!isset($kafka['topic']) || empty($kafka['topic'])) {
|
||||||
throw new Exception('kafka configure error.');
|
throw new Exception('kafka configure error.');
|
||||||
}
|
}
|
||||||
if (!isset($kafka['version']) || empty($kafka['version'])) {
|
if (!isset($kafka['version']) || empty($kafka['version'])) {
|
||||||
|
|||||||
Reference in New Issue
Block a user