From 3748efc6c835b9adbcdb9f86a235422362be40f0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 28 Oct 2020 11:51:43 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Kafka/KafkaProviders.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Kafka/KafkaProviders.php b/Kafka/KafkaProviders.php index 7042b8ab..c7874152 100644 --- a/Kafka/KafkaProviders.php +++ b/Kafka/KafkaProviders.php @@ -31,7 +31,7 @@ class KafkaProviders extends Providers if (empty($kafka) || !($kafka['enable'] ?? false)) { return; } - if (!isset($kafka['topics']) || empty($kafka['topics'])) { + if (!isset($kafka['topic']) || empty($kafka['topic'])) { throw new Exception('kafka configure error.'); } if (!isset($kafka['version']) || empty($kafka['version'])) {