diff --git a/Common/i18n/messages/plugins.go b/Common/i18n/messages/plugins.go
index 4a96702..d476bf9 100644
--- a/Common/i18n/messages/plugins.go
+++ b/Common/i18n/messages/plugins.go
@@ -576,6 +576,28 @@ var PluginMessages = map[string]map[string]string{
 		LangZH: "IMAP认证失败: %v",
 		LangEN: "IMAP authentication failed: %v",
 	},
+	
+	// ========================= Kafka插件消息 =========================
+	"kafka_weak_pwd_success": {
+		LangZH: "Kafka弱密码: %s [%s:%s]",
+		LangEN: "Kafka weak password: %s [%s:%s]",
+	},
+	"kafka_unauth_access": {
+		LangZH: "Kafka服务 %s 无需认证即可访问",
+		LangEN: "Kafka service %s allows unauthorized access",
+	},
+	"kafka_service_identified": {
+		LangZH: "Kafka服务识别成功: %s - %s",
+		LangEN: "Kafka service identified: %s - %s",
+	},
+	"kafka_connection_failed": {
+		LangZH: "Kafka连接失败: %v",
+		LangEN: "Kafka connection failed: %v",
+	},
+	"kafka_auth_failed": {
+		LangZH: "Kafka认证失败: %v",
+		LangEN: "Kafka authentication failed: %v",
+	},
 	"ftp_directory_found": {
 		LangZH: "发现FTP目录: %s",
 		LangEN: "FTP directories found: %s",
diff --git a/Core/Registry.go b/Core/Registry.go
index 362275a..02f1521 100644
--- a/Core/Registry.go
+++ b/Core/Registry.go
@@ -10,6 +10,7 @@ import (
 	_ "github.com/shadow1ng/fscan/plugins/services/cassandra"
 	_ "github.com/shadow1ng/fscan/plugins/services/ftp"
 	_ "github.com/shadow1ng/fscan/plugins/services/imap"
+	_ "github.com/shadow1ng/fscan/plugins/services/kafka"
 	_ "github.com/shadow1ng/fscan/plugins/services/mysql"
 	_ "github.com/shadow1ng/fscan/plugins/services/redis" 
 	_ "github.com/shadow1ng/fscan/plugins/services/ssh"